[C++知识库] C++多线程卡死问题--访问冲突未必崩溃

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> C++知识库 -> C++多线程卡死问题--访问冲突未必崩溃 -> 正文阅读

[C++知识库]C++多线程卡死问题--访问冲突未必崩溃

//上游调用到这里起线程
void DataCenter::start()
{
	auto dataMap = getData();
	vector<boost::thread> ths;
	for (const auto& item : dataMap )
	{
	   ths.push_back(boost::thread(boost::bind(&DataCenter::doCompose, this, item.second)));
	}
	for (vector<boost::thread>::iterator it=ths.begin();it!=ths.end() ; ++it)
	{
	   if (it->joinable())
	   {
	       it->join(); //doCompose里面访问map冲突卡住还是这么的，这里一直等待...
	   }
	}
	
	//boost::thread_group group;
	//for (const auto& item : dataMap )
	//{
	//    group.create_thread(boost::bind(&DataCenter::doCompose, this, item.second));
	//}
	//group.join_all();
}

//200多行的大方法，有节省
void DataCenter::doCompose(const map<string, map<string, vector<int64_t> > >& data)
{
   //....
   //因为这里没有加锁，偶发冲突，线程可能卡住了。
   //并没有引起整个程序的崩溃，被误为处理得慢了。   
   WriteLock wLock(m_lockDataMap);
   m_dataMap[key] = dt;
   //....                  
}