2015-02-09 102 views
0

我是C++線程的新手,但我已經做了足夠的閱讀,至少可以獲得我正在編譯的內容。到目前爲止,它還沒有改善性能。現在我只是讓它創建線程的數量,因爲有循環,但我可以想象,這可能會很快導致系統顛簸。有更好的選擇來控制線程數量嗎?我也打算在WestGrid計算系統上運行這個系統,我可以指定要使用的處理器數量。設置線程數量以優化處理器數量的最佳方法是什麼?C++多線程優化

void ExecuteCRTProcess(const long &numberOfRows, ZZ* rij, const ZZ &powRoh, const int &rowLength, long* PublicKey, ZZ* rQ0, const ZZ &Q0, ZZ* primes, const ZZ &productOfPrimes, ZZ* resultsArray, const bool IsItPrimeArray, long* caseStudy, long* caseStudyTracker, const ZZ &X0, const long &Roh){ 
int rc; 
pthread_t threads[numberOfRows]; 
struct parameters ThreadParameters[numberOfRows]; 

for(int i = 0; i< numberOfRows ; i++){ 
    FillR(rij,powRoh,rowLength); // fill up the vector rij with random numbers between 0 powRoh 
    MultiplyVectorByTwo(rij, rowLength, i, IsItPrimeArray); //Multiply rij vector by 2. If calculating Xi' also add 1 to appropriate values. 
    ThreadParameters[i].rij = rij; 
    ThreadParameters[i].rQ0 = rQ0; 
    ThreadParameters[i].primes = primes; 
    ThreadParameters[i].rowLength = rowLength; 
    ThreadParameters[i].Q0 = Q0; 
    ThreadParameters[i].i = i; 
    ThreadParameters[i].X0 = X0; 
    rc = pthread_create(&threads[i],NULL,CRTNew,(void *)&ThreadParameters[i]); 
    if(rc){ 
     cout << "Error: unable to create thread, " << rc << endl; 
     exit(-1); 
    } 
    for(long j = 0; j< rowLength; j++){ 
     cout << (resultsArray[i] % primes[j]) << " "; 
    } 
    cout << endl;*/ 

} 
for(int i = 0; i< numberOfRows; i++){ 
    pthread_join(threads[i], NULL); 
    resultsArray[i] = ThreadParameters[i].result; 
    } 
} 

的線程創建運行該功能

void* CRTNew(void *threadArg){ 
    struct parameters *local_data; 
    local_data = (struct parameters *) threadArg; 
    ZZ a, p, A, P, crt; 
    long Z, Public; 
    a = local_data->rQ0[local_data->i]; 
    p = local_data->Q0; 
    A = local_data->rij[0]; 
    P = local_data->primes[0]; 
    for(int i = 1; i<=local_data->rowLength; i++){ 
     A = A%P; 
     Z = CRT(a, p, A, P); 
     A = local_data->rij[i]; P = local_data->primes[i]; 
     if(i == local_data->rowLength) Public = Z; 
    } 
    if(a < 0) crt = a+p; 
    else crt = a%p; 
    local_data->result = crt%local_data->X0; 
    pthread_exit(NULL); 

}

+2

你能夠使用C++ 11嗎?如果是這樣,我強烈推薦使用std :: thread和它的所有精彩的線程榮耀而不是pthread。 – Julian 2015-02-09 20:43:06

回答

0

「什麼是設置線程數來優化處理器數量的最佳途徑」;

1)在應用程序啓動時創建[核心數量]線程(或者更多)。

2)不要產生任何更多的線程

3)不要讓你的線程終止。

4)讓他們按照池的方式等待生產者 - 消費者線程上的工作任務。

或者,使用已經工作的線程池類或等效的並行語言功能。