dee*_*e86 9 c++ concurrency multithreading segmentation-fault c++11
我有一个问题(segfault)在C++ 11中运行多线程代码.这是代码:
#include <vector>
#include <thread>
std::vector<int> values;
int i;
void values_push_back()
{
values.push_back(i);
}
int main()
{
while(true)
{
std::vector<std::thread> threads;
for(i=0; i<10; ++i)
{
std::thread t(values_push_back);
threads.push_back(std::move(t));
}
for(i=0; i<10; ++i)
threads[i].join();
}
return 0;
}
Run Code Online (Sandbox Code Playgroud)
这里是gdb上的回溯:http://pastebin.com/5b5TN70c
这有什么不对?
hmj*_*mjd 14
这与移动无关.
多个线程vector::push_back()在同一个线程上执行,vector但
vector::push_back()不是线程安全的.vector需要同步的修改.
A std::mutex可用于将调用同步到push_back():
std::vector<int> values;
std::mutex values_mutex;
void values_push_back()
{
values_mutex.lock();
values.push_back(i);
values_mutex.unlock();
}
Run Code Online (Sandbox Code Playgroud)
此外,变量i在线程之间共享而没有同步,这将导致竞争条件(可能的结果是int添加了重复的s vector).考虑将int值作为参数传递给线程以避免这种情况:
std::vector<int> values;
std::mutex values_mutex;
void values_push_back(int i)
{
values_mutex.lock();
values.push_back(i);
values_mutex.unlock();
}
for (int i = 0; i < 10; ++i)
{
threads.push_back(std::thread(values_push_back, i));
}
for (auto& t: threads) t.join();
Run Code Online (Sandbox Code Playgroud)
如bamboon所评论的那样,更喜欢std::lock_guard确保在push_back()抛出时释放锁(在这种情况下只能是这样bad_alloc()但是如果vector更改以保存具有抛出构造函数的更复杂的对象则变得更加重要):
void values_push_back(int i)
{
std::lock_guard<std::mutex> lk(values_mutex);
values.push_back(i);
}
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
9595 次 |
| 最近记录: |