问题描述:有80个计算状态(popsize = 80),现在计划用10核计算(建立10个线程nThreadCount = 10),由于每个状态的计算时间不同(不可预测,大概在15分钟以内),为了节省计算时间,计划一个线程的计算状态完成后,紧跟着将紧跟着的下一个计算状态调入计算(不关闭线程),但是计算结果发现:传进评估函数(test_problem函数)的计算结果与变量不对应,即传进去的变量算得到的结果被赋给其他变量了。郁闷!求高手帮忙!
//线程建立函数
void create_proc(population *pop)
{
int i;
HANDLE* threads = new HANDLE[nThreadCount]; // 线程句柄,nThreadCount = 10
thread_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里面调用了一个DLL
test_problem (ind->xreal, ind->obj);
return;
}
高手帮忙解答,感谢不尽,在线等,有疑问请回复
qq_遁去的一_1
翻翻过去那场雪