为什么传进去的变量算得到的结果被赋给其他变量了

问题描述:有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;
}

高手帮忙解答,感谢不尽,在线等,有疑问请回复

Helenr
浏览 70回答 2
2回答

qq_遁去的一_1

自己安排线程太累了。用OMP吧。#pragma omp parallel for超级简单。VS2005以后就有了。不学就落伍啦。

翻翻过去那场雪

malloc一份新的的参数pop参数传到TaskThreadProc这个里面
打开App,查看更多内容
随时随地看视频慕课网APP