Question

c++多线程编程

for (int i=0;i<vStationNum;i++)
{
m_CorDList.clear();
for(std::list<RecDist>::iterator vIti = m_Data.m_RDistList[i].begin(); vIti != m_Data.m_RDistList[i].end(); vIti++)
{
int istate = vIti->mystate;
m_CorDList.clear();
rdist = *vIti;
m_CorDList.push_back(rdist);

for(int j = i+1; j < vStationNum ;j++)
{
for(std::list<RecDist>::iterator vItj = m_Data.m_RDistList[j].begin(); vItj != m_Data.m_RDistList[j].end(); vItj++)
{
int jstate = vItj->mystate;
if (abs(jstate-istate)==0)
{
rdist = *vItj;
m_CorDList.push_back(rdist);
}
}
}

if (m_CorDList.size()>=5)//如果记录条数（站的个数）大于等于4
{
TDOAPos posTaylor;
posTaylor.x = 0;
posTaylor.y = 0;
posTaylor.z = 0;
std::map<int, TDOAPos> mapChan;//存储返回Chan方法中的主站号以及位置信息

mapChan = m_pAlgorithmImp->MyCalPosByChan_Over4Station(m_CorDList);//Chan方法估计位置返回主站号与位置信息//向mapChan写入数据

std::map<int, TDOAPos>::const_iterator map_Ite = mapChan.begin();
int baseA = map_Ite->first; //主站号

TDOAPos posChan;//Chan位置坐标
posChan.x = map_Ite->second.x;
posChan.y = map_Ite->second.y;
posChan.z = map_Ite->second.z;
vChanPos.push_back(posChan);//存储Chan得到的位置信息

posTaylor = m_pAlgorithmImp->MyTalyorMethod_Test(baseA, posChan, m_CorDList);//对Chan方法得到的数据进行泰勒迭代修正

vTayLorPos.push_back(posTaylor);
}
}
}
请问，现在我想用多线程实现这个操作，前面读取数据放在m_CorDList，如果大于等于5就执行下面的操作，我想将读取数据和if{}操作能不能用两个线程实现，一个是读取数据放在m_CorDList，另一个就是if{}操作。没接触过多线程，希望高手指点，最好给出详细实现过程！谢谢

Answer 1

这应该是内存共享式的多线程，要注意的是要设定好互斥访问信号量，如果没设信号量，假如正好在判断m_CorDList数据个数时（假如当时数据数小于5）的同时另一线程又住m_CorDList里添加数据，在下一次的if判断时m_CorDList中的数据个数就可能远远多于5个，加入互斥访问信号量，在if判断时不允许其他线程往m_CorDList中写数据，而且在添加数据的线程在每添加数据之前也要先判断m_CorDList中数据是否大于等于5个，如果大于等于5个就不要添加。

追问

 

//线程函数

DWORD WINAPI CTDOAView::MyProcData_Thread(LPVOID pParam)
{
 Str_Dist *vStr_Dist = (Str_Dist*)pParam;

{

    //中间操作省略

}

delete vStr_Dist;
 return 0;
}

 

现在会出现错误。不知道什么原因？

Answer 2

加一个互斥量和条件变量，在读取数据线程读取完数据判断是否大于5，大于5激活条件变量，处理线程开始工作处理数据。
处理线程在数据量小于5时候wait条件变量，一旦条件变量被激活开始处理。
很简单，看看Windows核心编程。

追问

for循环中是读取m_Data中数据，读取完后，判断是否大于5，大于5就处理，处理完以后再读取数据进行处理。这是顺序执行的流程，用多线程实现的话，主要是不知道读取m_Data数据操作怎么写，难道还是for循环吗？for循环中i是变的，所以数据每次也不一样。现在很迷糊，不知道如何将顺序的改成多线程（我只知道上面的应该可以使用两个线程来实现）。还请高手帮下忙，谢谢

追答

不太明白你这么做的意义。不过感觉你应该把上面的所有单独放到一个线程里面，在主线程里面只用判断一下m_Data的数据量就行了，其他的交给工作线程去做就行了。

追问

因为如果不用多线程的话这样只是顺序执行，数据量比较大的时候执行起来会比较忙，要等待一段时间才能执行完，我就想能不能读取完数据的时候，对数据进行处理，然后读取数据线程继续读，这样相当是并发执行

追答

嗯，我说的意义不明就是不知道你m_Data是干嘛的，因为没看见你删除里面的元素。

如果以下两个函数

m_pAlgorithmImp->MyCalPosByChan_Over4Station()
m_pAlgorithmImp->MyTalyorMethod_Test()

占用大量程序时间的话，而且你只关心posTaylor这个结果的话，直接上线程池，把读取完的数据移交给线程池读取工作就完了，其他的交由线程池工作线程(也就是以上两个函数)处理数据并将结果压送回vTayLorPos。

追问

追答

如果你的m_CorDList只是个中间缓冲的话而且你只关心posTaylor的话就没必要用互斥量了，现在你只是需要一个线程来帮你运算罢了，不必考虑线程同步的问题，所以你直接把m_CorDList当做参数传递到线程函数里面然后让工作线程帮你运算。
线程函数必须是全局函数才行，你刚才的是成员函数是无法创建线程的。

追问

追答

其实上已经节省了时间了，现在这个程序相当于在读取完数据后就立即开始读取下一批数据，你的工作线程事实上已经帮你节省了处理的那部分时间。
现在的话首先你需要把你接收过来的数据先判断一下是否大于5，然后将接收过来的数据做一份拷贝，然后将拷贝传递给线程函数，然后m_CorDList就能放心clear然后接收下一批数据，这样你的接收线程函数就能不停地接收并且创建线程进行处理，推荐你采用线程池是因为如果把握不好线程的数量，线程会成倍增长最终降低性能。

追问

请问，这样有问题吗？我运行以后等了好久都没出结果。

追答

单步调试，看看线程是不是创建了，在运行没。

追问

太奇怪了，为什么vStrDist.m_CorList = m_CorDList;只有一个元素，运行线程函数的时候if条件竟然>=5？执行了。而且线程函数中的vStr_Dist->m_CorList没有元素，是空的啊。晕了。。。，接着因为没有元素，后面就会报错了。这可把我弄晕了

追答

注意分配空间，现在是两个线程，跨线程的数据很容易在另一个线程被释放，就会出现这种状况。

追问

因为被共享的是m_CorDlist，所以我就将m_CorDList放在新开辟出来的一个结构中，但是这样还是不行，虽然能进入线程函数，但是条件不符合，所以就没有执行那些语句，最后结果就是空的。还请指教，谢了

追答

两处错误。

1. 参数传递不对。

   (LPVOID)&vStrDist  //这里对指针取地址和你线程函数里面强制转换不符

2. 在线程函数未执行完毕或尚未执行就已经delete  vStrDist，这里的vStrDist应该在线程函数里面delete。

Answer 3

读写分来2个函数

读函数 写函数 各放入一条线程
然后对m_CorDList读写加锁 注意同步互斥就行了

可以这样理解 写函数是生产者 读函数是 消费者 典型的生产者消费者模型