并发环境中的C++ 11 std :: vector

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()在同一个线程上执行,vectorvector::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)

  • 您的代码不是异常安全的.如果push_back抛出,你将死锁,改为使用`std :: lock_guard`. (10认同)