此代码是从向量中添加和删除项目的线程安全方式吗？

Question

我试图很好地理解线程安全，所以，我有一个简单的代码（代码不是真实的），我已经应用了线程安全，如下所示：

vector<int> myList;
const unsigned short ListSize = 5;
mutex mut;
condition_variable cond;

void AddItem() {
    for (int i = 0; i < ListSize + 2; i++) {
        mut.lock();
        myList.push_back(i);
        mut.unlock();
        cond.notify_one();
        cout << "An item added." << "\n";
        this_thread::sleep_for(chrono::milliseconds(300));
    }
}

void RemoveItem() {
    for (int i = 0; i < ListSize; i++) {
        unique_lock<mutex> locker(mut);
        cond.wait(locker, []() { return !myList.empty(); });
        myList.erase(myList.begin());
        cout << "An item removed." << "\n";
        this_thread::sleep_for(chrono::milliseconds(300));
    }
}


int main() {

    thread th_task1(&AddItem);
    thread th_task2(&RemoveItem);
    th_task1.join();
    th_task2.join();

    if (!myList.empty()) {
        cout << "There are " << myList.size() << " items." << "\n";
    } else {
        cout << "The list is empty." << "\n";
    }

    return 0;
}

另外，您可以测试来自here 的代码。

该代码是否被认为是线程安全的？如果不是如何使其成为线程安全的？

Answer 1

它是线程安全的（例如，你应该在应该锁定的时候锁定，并正确地执行wait），但它不是一个很好的线程使用，因为你只会在添加线程完全完成时通知删除线程。

所以你也可以直接从main 拨打AddItem() 然后RemoveItem()。

另外，虽然我知道休眠只是为了试验，但您可能需要考虑将这些休眠从锁中取出，否则，您再次创建大量争用，从而阻止多线程在任何方面都有用。