問題描述:有80個計算狀態(popsize = 80),現在計劃用10核計算(建立10個線程nThreadCount = 10),由于每個狀態的計算時間不同(不可預測,大概在15分鐘以內),為了節省計算時間,計劃一個線程的計算狀態完成后,緊跟著將緊跟著的下一個計算狀態調入計算(不關閉線程),但是計算結果發現:傳進評估函數(test_problem函數)的計算結果與變量不對應,即傳進去的變量算得到的結果被賦給其他變量了。郁悶!求高手幫忙!//線程建立函數void create_proc(population *pop){int i;HANDLE* threads = new HANDLE[nThreadCount]; // 線程句柄,nThreadCount = 10thread_pos = 0;hMutex = CreateMutex(NULL,FALSE,NULL); // 建立互斥對象for (i = 0; i < nThreadCount; i++){threads[i] = CreateThread( NULL, 0, TaskThreadProc, pop, 0, NULL); // 創建線程thread_pop_pos[i] = 0;SetThreadAffinityMask(threads[i], 1<<i); //分配核計算if (threads[i] == NULL) { printf("\n thread %d have not been created sucessfully, hence exiting", i);system("pause");exit(1); } SuspendThread(threads[i]);}for(i = 0; i <nThreadCount; i++){ResumeThread(threads[i]);Sleep(1000);}WaitForMultipleObjects(nThreadCount, threads, TRUE, INFINITE); // 等待線程運行結束for (i = 0; i < nThreadCount; i++)CloseHandle(threads[i]); // 銷毀線程delete [] threads;}// 線程函數DWORD WINAPI TaskThreadProc( LPVOID lpParameter ){population *pop = (population *) lpParameter; //pop 包括所有的計算狀態evaluate_pop (pop);return 0;}// 這個函數要評估所有的80個狀態void evaluate_pop (population *pop){int ind_count; //每個線程正在評估的個體do{ ind_count = thread_pos; // 將全局賦給局部變量evaluate_ind (&(pop->ind[ind_count])); // 調用單個狀態評估函數}while(thread_pos < popsize);return;}void evaluate_ind (individual *ind){int j;WaitForSingleObject(hMutex,INFINITE);thread_pos++; // 全局變量,當前共評估到那個狀態ReleaseMutex(hMutex);// ind->xreal 變量共10個DOUBLE型數據,ind->obj要得到的變量值,共2個// test_problem里面調用了一個DLLtest_problem (ind->xreal, ind->obj); return;}高手幫忙解答,感謝不盡,在線等,有疑問請回復
添加回答
舉報
0/150
提交
取消