c++ - 将对象传递给两个 std::threads

Question

如果我创建一个将被两个不同的 std::threads 访问的对象，我是否需要在创建对象或将其传递给线程时进行任何特殊规定？

例如:

class Alpha
{
public:
    int x;
};

void Foo(Alpha* alpha)
{
    while (true)
    {
        alpha->x++;
        std::cout << "Foo: alpha.x = " << alpha->x << std::endl;
    }
}

void Bar(Alpha* alpha)
{
    while (true)
    {
        alpha->x++;
        std::cout << "Bar: alpha.x = " << alpha->x << std::endl;
    }
}

int main(int argc, char * argv[])
{
    Alpha alpha;
    alpha.x = 0;
    std::thread t1(Foo, &alpha);
    std::thread t2(Bar, &alpha);
    t1.join();
    t2.join();

    return 0;
}

这编译得很好，似乎也运行得很好。但是我没有明确地告诉我的程序 alpha 需要被两个不同的线程访问。我应该采取不同的做法吗？

Answer 1

您在 alpha.x 上有竞争条件，因为两个线程都可以在另一个读/写它的值时写入。您可以通过更改 x 的类型来解决此问题进入std::atomic<int>或者通过使用互斥锁来保护读/写访问。