双核CPU上的快速排序效率

为了试验一下多核CPU上排序算法的效率,得比较单任务情况下和多任务并行排序算法的差距,因此选用快速排序算法来进行比较。

10年积累的成都网站设计、做网站经验,可以快速应对客户对网站的新想法和需求。提供各种问题对应的解决方案。让选择我们的客户得到更好、更有力的网络服务。我虽然不认识你,你也不认识我。但先网站制作后付款的网站建设流程,更有云南免费网站建设让你可以放心的选择与我们合作。

测试环境:双核CPU 2.66GHZ

                    单核CPU 2.4GHZ

以下是一个快速排序算法的源代码:

 
 
 
  1. UINTSplit(void **ppData, UINTuStart, UINTuEnd, 
  2.                      COMPAREFUNCCompareFunc) 
  3. { 
  4.     void *pSelData; 
  5.     UINTuLow; 
  6.     UINTuHigh; 
  7.   
  8.     uLow = uStart; 
  9.     uHigh = uEnd; 
  10.   
  11.     pSelData = ppData[uLow]; 
  12.     while ( uLow < uHigh ) 
  13.     { 
  14.         while ( (*CompareFunc)(ppData[uHigh], pSelData) > 0 
  15.             && uLow != uHigh ) 
  16.         { 
  17.             --uHigh; 
  18.         } 
  19.         if ( uHigh != uLow ) 
  20.         { 
  21.             ppData[uLow] = ppData[uHigh]; 
  22.             ++uLow; 
  23.         } 
  24.   
  25.         while ( (*CompareFunc)( ppData[uLow], pSelData ) < 0 
  26.             && uLow != uHigh ) 
  27.         { 
  28.              ++uLow; 
  29.         } 
  30.         if ( uLow != uHigh ) 
  31.         { 
  32.             ppData[uHigh] = ppData[uLow]; 
  33.             --uHigh; 
  34.         } 
  35.     } 
  36.     ppData[uLow] = pSelData; 
  37.   
  38.     returnuLow; 
  39. } 
  40.   
  41.   
  42. voidQuickSort(void **ppData, UINTuStart, UINTuEnd, 
  43.                         COMPAREFUNCCompareFunc) 
  44. { 
  45.     UINTuMid = Split(ppData, uStart, uEnd, CompareFunc ); 
  46.     if ( uMid > uStart ) 
  47.     { 
  48.         QuickSort(ppData, uStart, uMid - 1, CompareFunc); 
  49.     } 
  50.   
  51.     if ( uEnd > uMid ) 
  52.     { 
  53.         QuickSort(ppData, uMid + 1, uEnd, CompareFunc); 
  54.    } 
  55. } 

先测试一下这个快速排序算法排一百万个随机整数所花的时间:

 
 
 
  1. voidTest_QuickSort(void) 
  2. { 
  3.     UINTi; 
  4.     UINTuCount = 1000000; //1000000个 
  5.   
  6.     srand(time(NULL)); 
  7.     void **pp = (void **)malloc(uCount * sizeof(void *)); 
  8.     for ( i = 0; i < uCount; i++ ) 
  9.     { 
  10.         pp[i] = (void *)(rand() % uCount); 
  11.     } 
  12.   
  13.        clockclock_tt1 = clock(); 
  14.     QuickSort(pp, 0, uCount-1, UIntCompare); 
  15.        clockclock_tt2 = clock(); 
  16.   
  17.        printf("QuickSort 1000000 Time %ld/n", t2-t1); 
  18.   
  19.     free(pp); 
  20. } 

在双核CPU2.66GHZ机器上运行测试程序,打印出花费的时间约为406 ms

在单核CPU2.4GHZ机器上运行测试程序,打印出花费时间约为484ms

可见在双核CPU上运行单任务程序和单核CPU基本是一样的,效率没有任何提高。

下面再来把上面的快速排序程序变成并行的,一个简单的方法就是将要排序的区间分成相同的几个段,然后对每个段进行快速排序,排序完后再使用归并算法将排好的几个区间归并成一个排好序的表,我们先四个线程来进行排序,代码如下:

 
 
 
  1. void ** Merge(void **ppData, UINTuStart, UINTuEnd, 
  2.        void **ppData2, UINTuStart2, UINTuEnd2, COMPAREFUNCcfunc) 
  3. { 
  4.     UINTi, j, k; 
  5.     UINTu1, u2, v1,v2; 
  6.     void **pp1; 
  7.     void **pp2; 
  8.   
  9.     void **pp = (void **)malloc( (uEnd-uStart+1+uEnd2-uStart2+1) * sizeof(void *)); 
  10.     if ( pp == NULL ) 
  11.     { 
  12.         returnNULL; 
  13.     } 
  14.   
  15.     if ( (*cfunc)(ppData2[uStart2], ppData[uStart]) > 0 ) 
  16.     { 
  17.         u1 = uStart; 
  18.         u2 = uEnd; 
  19.         v1 = uStart2; 
  20.         v2 = uEnd2; 
  21.         pp1 = ppData; 
  22.         pp2 = ppData2; 
  23.     } 
  24.     else 
  25.     {        
  26.         u1 = uStart2; 
  27.         u2 = uEnd2; 
  28.         v1 = uStart; 
  29.         v2 = uEnd; 
  30.         pp1 = ppData2; 
  31.         pp2 = ppData; 
  32.     } 
  33.   
  34.     k = 0; 
  35.     pp[k] = pp1[u1]; 
  36.     j = v1; 
  37.     for (i = u1+1; i <= u2; i++ ) 
  38.     { 
  39.         while ( j <= v2 ) 
  40.         { 
  41.             if ( (*cfunc)(pp2[j], pp1[i]) < 0 ) 
  42.            { 
  43.                 ++k; 
  44.                 pp[k] = pp2[j]; 
  45.                 j++; 
  46.             } 
  47.             else 
  48.             { 
  49.                 break; 
  50.             } 
  51.         } 
  52.         ++k; 
  53.         pp[k] = pp1[i]; 
  54.     } 
  55.   
  56.     if ( j < v2 ) 
  57.     { 
  58.         for ( i = j; i <= v2; i++) 
  59.         { 
  60.             ++k; 
  61.             pp[k] = pp2[i]; 
  62.         } 
  63.     } 
  64.     returnpp; 
  65. } 
  66.   
  67. typedefstructSORTNODE_st { 
  68.        void **           ppData; 
  69.        UINT             uStart; 
  70.        UINT             uEnd; 
  71.        COMPAREFUNCfunc; 
  72. } SORTNODE; 
  73.   
  74.   
  75. DWORDWINAPIQuickSort_Thread(void *arg) 
  76. { 
  77.        SORTNODE   *pNode = (SORTNODE *)arg; 
  78.        QuickSort(pNode->ppData, pNode->uStart, pNode->uEnd, pNode->func); 
  79.        return 1; 
  80. } 
  81.   
  82. #define THREAD_COUNT    4 
  83.   
  84. INTMQuickSort(void **ppData, UINTuStart, UINTuEnd, 
  85. COMPAREFUNCCompareFunc) 
  86. { 
  87.     void **pp1; 
  88.     void **pp2; 
  89.     void **pp3; 
  90.        INT               i; 
  91.        SORTNODE   Node[THREAD_COUNT]; 
  92.        HANDLE        hThread[THREAD_COUNT]; 
  93.   
  94.        INT        nRet = CAPI_FAILED; 
  95.   
  96.        for ( i = 0; i < THREAD_COUNT; i++) 
  97.        { 
  98.               Node[i].ppData = ppData; 
  99.               if ( i == 0 ) 
  100.               { 
  101.                      Node[i].uStart = uStart; 
  102.               } 
  103.               else 
  104.               { 
  105.                      Node[i].uStart = uEnd * i /THREAD_COUNT + 1;  
  106.               } 
  107.               Node[i].uEnd = uEnd *(i+1) / THREAD_COUNT; 
  108.               Node[i].func = CompareFunc; 
  109.   
  110.               hThread[i] = CreateThread(NULL, 0, QuickSort_Thread, &(Node[i]), 0, NULL); 
  111.        } 
  112.   
  113.        for ( i = 0; i < THREAD_COUNT; i++ ) 
  114.        { 
  115.               WaitForSingleObject(hThread[i], INFINITE); 
  116.        } 
  117.   
  118.   
  119.     pp1 = Merge(ppData, uStart, uEnd/4, ppData, uEnd/4+1, uEnd/2, CompareFunc); 
  120.   
  121.     pp2 = Merge(ppData, uEnd/2+1, uEnd*3/4, ppData, uEnd*3/4+1, uEnd, CompareFunc); 
  122.   
  123.     if ( pp1 != NULL && pp2 != NULL ) 
  124.     { 
  125.         pp3 = Merge(pp1, 0, uEnd/2-uStart, pp2, 0, uEnd - uEnd/2 - 1, CompareFunc); 
  126.   
  127.         if ( pp3 != NULL ) 
  128.         { 
  129.             UINTi; 
  130.           
  131.             for ( i = uStart; i <= uEnd; i++) 
  132.             { 
  133.                 ppData[i] = pp3[i-uStart]; 
  134.             } 
  135.             free(pp3); 
  136.             nRet = CAPI_SUCCESS; 
  137.         } 
  138.     } 
  139.     if( pp1 != NULL) 
  140.     { 
  141.         free( pp1 ); 
  142.     } 
  143.     if ( pp2 != NULL ) 
  144.     { 
  145.         free( pp2 ); 
  146.     } 
  147.   
  148.     returnnRet; 
  149. } 

#p#

用下面程序来测试一下排1百万个随机整数的花费时间:

 
 
 
  1. voidTest_MQuickSort (void) 
  2. { 
  3.     UINTi; 
  4.     UINTuCount = 1000000; //1000个 
  5.   
  6.     srand(time(NULL)); 
  7.     void **pp = (void **)malloc(uCount * sizeof(void *)); 
  8.     for ( i = 0; i < uCount; i++ ) 
  9.     { 
  10.         pp[i] = (void *)(rand() % uCount); 
  11.     } 
  12.   
  13.        clockclock_tt1 = clock(); 
  14.     INTnRet = MQuickSort(pp, 0, uCount-1, UIntCompare); 
  15.        clockclock_tt2 = clock(); 
  16.   
  17.        printf("MQuickSort 1000000 Time %ld/n", t2-t1); 
  18.   
  19.     free(pp); 
  20. } 

在双核CPU上运行后,打印出花费的时间为 234 ms , 单任务版的快速排序函数约需406ms左右,并行运行效率为:406/(2×234) = 86.7% 左右。运行速度快了172ms。

可见双核CPU中,多任务程序速度还是有很大提高的。

当然上面的多任务版的快速排序程序还有很大的改进余地,当对4个区间排好序后,后面的归并操作都是在一个任务里运行的,对整体效率会产生影响。估计将程序继续优化后,速度还能再快一些。

原文链接:http://blog.csdn.net/drzhouweiming/article/details/1109499


网站题目:双核CPU上的快速排序效率
URL网址:http://jxruijie.cn/article/djcooih.html