C/C++多線程怎么單線程還慢

方兆國

我這兩天看Java多線程編程,順便把程序改成了C/C++多線程的,然后發(fā)現(xiàn)debug版本的運行速度還沒有單線程的和java版的快,而且差距不�。�
release版的目前還沒有出現(xiàn)過結(jié)果……

這是什么情況

天不再藍

cpu單核的？

方兆國

天不再藍 發(fā)表于 2013-07-19 16:42
cpu單核的？

Intel i5 430M 虛擬四核

方兆國

C語言版源代碼

1. 
   
2. #include <pthread.h>
   
3. #include <stdio.h>
   
4. #include <malloc.h>
   
5. #include <math.h>
   
6. #include <time.h>
   
7. 
   
8. typedef struct {
   
9.         int id;
   
10.         long lower;
    
11.         long upper;
    
12.         int total;
    
13. } Message;
    
14. 
    
15. int flag[4] = { 0, 0, 0, 0 };  //用于確定線程是否執(zhí)行完畢
    
16. 
    
17. int isPrime(long number) {
    
18.         if (1 >= number) {
    
19.                 return 0;
    
20.         }
    
21.         long i;
    
22.         for (i = 2; i <= sqrt(number); i++) {
    
23.                 if (0 == number % i) {
    
24.                         return 0;
    
25.                 }
    
26.         }
    
27.         return 1;
    
28. }
    
29. 
    
30. void *countPrimeInRange(void* mess) {
    
31.         long i = 0;
    
32.         Message* message = (Message*) mess;
    
33.         for (i = message->lower; i < message->upper; i++) {
    
34.                 if (isPrime(i)) {
    
35.                         message->total++;
    
36.                 }
    
37.         }
    
38.         flag[message->id] = 1;
    
39.         return NULL;
    
40. }
    
41. 
    
42. int countPrime(long number) {
    
43.         int total = 0;
    
44.         pthread_t thread[4];
    
45.         Message *message[4];
    
46.         long start = 0, end = 0;
    
47.         long range = number / 4;
    
48.         int i = 0;
    
49.         for (i = 0; i < 4; i++) {
    
50.                 message[i] = (Message*) malloc(sizeof(Message));
    
51.         }
    
52.         for (i = 0; i < 4; i++) {
    
53.                 start = 0 + range * i;
    
54.                 if (i < 3) {
    
55.                         end = start + range;
    
56.                 } else {
    
57.                         end = number;
    
58.                 }
    
59.                 message[i]->id = i;
    
60.                 message[i]->lower = start;
    
61.                 message[i]->upper = end;
    
62.                 message[i]->total = 0;
    
63.                 pthread_create(&thread[i], NULL, countPrimeInRange,
    
64.                                 (void*) (message[i]));
    
65.         }
    
66.         i = 0;
    
67.         while (i < 4) {
    
68.                 if (1 == flag[i]) {
    
69.                         total += message[i]->total;
    
70.                         i++;
    
71.                 }
    
72.         }
    
73.         return total;
    
74. }
    
75. 
    
76. int main(int argc, char *argv[]) {
    
77.         time_t start, end;
    
78.         time(&start);
    
79.         int sum = countPrime(10000000);
    
80.         time(&end);
    
81.         printf("0-10000000之間有%ld個素數(shù)\n", sum);
    
82.         printf("程序運行時間%d秒\n", end - start);
    
83.         return 0;
    
84. }
    

復(fù)制代碼

方兆國

Boost版源代碼

Main函數(shù)所在文件

1. #include "ConcurrentPrimeFinder.h"
   
2. 
   
3. #include <stdio.h>
   
4. #include <time.h>
   
5. 
   
6. int main(int argc, char *argv[]) {
   
7.         time_t start, end;
   
8.         ConcurrentPrimeFinder finder;
   
9.         time(&start);
   
10.         int sum = finder.countPrime(10000000);
    
11.         time(&end);
    
12.         printf("0-10000000之間有%ld個素數(shù)\n", sum);
    
13.         printf("程序運行時間%d秒\n", end - start);
    
14.         return 0;
    
15. }
    

復(fù)制代碼

1. /*
   
2. * ConcurrentPrimeFinder.h
   
3. *
   
4. *  Created on: 2013年7月19日
   
5. *      Author: root
   
6. */
   
7. 
   
8. #ifndef CONCURRENTPRIMEFINDER_H_
   
9. #define CONCURRENTPRIMEFINDER_H_
   
10. 
    
11. #include <boost/thread.hpp>
    
12. 
    
13. class ConcurrentPrimeFinder {
    
14. public:
    
15.         ConcurrentPrimeFinder();
    
16.         virtual ~ConcurrentPrimeFinder();
    
17.         int countPrime(long number);
    
18. 
    
19. private:
    
20.         int poolsize;
    
21. };
    
22. 
    
23. #endif /* CONCURRENTPRIMEFINDER_H_ */
    

復(fù)制代碼

1. /*
   
2. * ConcurrentPrimeFinder.cpp
   
3. *
   
4. *  Created on: 2013年7月19日
   
5. *      Author: root
   
6. */
   
7. 
   
8. #include "ConcurrentPrimeFinder.h"
   
9. 
   
10. ConcurrentPrimeFinder::ConcurrentPrimeFinder() {
    
11.         poolsize = 4;
    
12. 
    
13. }
    
14. 
    
15. ConcurrentPrimeFinder::~ConcurrentPrimeFinder() {
    
16. }
    
17. 
    
18. bool isPrime(long number) {
    
19.         if (1 >= number) {
    
20.                 return false;
    
21.         }
    
22.         long i;
    
23.         for (i = 2; i <= sqrt(number); i++) {
    
24.                 if (0 == number % i) {
    
25.                         return false;
    
26.                 }
    
27.         }
    
28.         return true;
    
29. }
    
30. 
    
31. void countPrimeInRange(long int lower, long int upper, int *total, bool *flag) {
    
32.         long i = 0;
    
33.         for (i = lower; i < upper; i++) {
    
34.                 if (isPrime(i)) {
    
35.                         (*total)++;
    
36.                 }
    
37.         }
    
38.         *flag = true;
    
39. }
    
40. 
    
41. int ConcurrentPrimeFinder::countPrime(long number) {
    
42.         using namespace boost;
    
43.         int total = 0, sum[4] = { 0 };
    
44.         bool flag[4] = { false };
    
45.         long start = 0, end = 0;
    
46.         long range = number / poolsize;
    
47.         int i = 0;
    
48.         for (i = 0; i < poolsize; i++) {
    
49.                 start = range * i;
    
50.                 if (i < poolsize - 1) {
    
51.                         end = start + range;
    
52.                 } else {
    
53.                         end = number;
    
54.                 }
    
55.                 thread mythread(
    
56.                                 bind(&countPrimeInRange, start, end, &(sum[i]), &(flag[i])));
    
57.         }
    
58.         i = 0;
    
59.         while (i < poolsize) {
    
60.                 if (flag[i]) {
    
61.                         total += sum[i];
    
62.                         i++;
    
63.                 }
    
64.         }
    
65.         return total;
    
66. }
    

復(fù)制代碼

方兆國

這兩個都是一個問題，debug版運行緩慢，release版，就像進入死循環(huán)了

littledick

volatile
lock
asynchronous

方兆國

回復(fù) 7# littledick


    剛剛發(fā)現(xiàn)一個很嚴(yán)峻的問題,連main函數(shù)開頭的printf都執(zhí)行不了

方兆國

littledick 發(fā)表于 2013-07-19 17:01
volatile
lock
asynchronous

真的非常感謝你,你說的三個單詞,我用了第一個就解決問題了,那個變量i被編譯器優(yōu)化了,因此一直是死循環(huán)出不來

yulihua49

方兆國 發(fā)表于 2013-07-19 16:40
我這兩天看Java多線程編程,順便把程序改成了C/C++多線程的,然后發(fā)現(xiàn)debug版本的運行速度還沒有單線程的和ja ...

這只是你的個例，不能作為普遍的結(jié)論。
一般多線程的設(shè)計，要依據(jù)業(yè)務(wù)性質(zhì)，在某些可并行的瓶頸環(huán)節(jié)設(shè)置多線程，才能獲得好的效果。

for (i = 2; i <= sqrt(number); i++) {

你能不能先把ｓｑｒｔ求出來，別每次循環(huán)做？