c++11 - C++11 std::threads 未退出

Question

您能否检查以下即使在条件变为 false 后也不会退出的代码？

我试图通过第一个线程打印从 1 到 10 的数字，同样通过第二个线程打印 2 到 20 并且我有 10 个线程，每当计数达到 100 时，我的程序应该通过终止所有线程来安全终止。但这并没有发生，打印后，它卡住了，我不明白为什么？

有数据竞赛吗？请指导。

#include<iostream>
#include<vector>
#include<thread>
#include<mutex>
#include<condition_variable>

std::mutex mu;
int count=1;
bool isDone = true;
std::condition_variable cv;

void Print10(int tid)
{
        std::unique_lock<std::mutex> lock(mu);
        while(isDone){
                cv.wait(lock,[tid](){ return ((count/10)==tid);});
                for(int i=0;i<10;i++)
                        std::cout<<"tid="<<tid<<" count="<<count++<<"\n";
                isDone = count<100;//!(count == (((tid+1)*10)+1));
                std::cout<<"tid="<<tid<<" isDone="<<isDone<<"\n";
                cv.notify_all();
        }
}
int main()
{
        std::vector<std::thread> vec;

        for(int i=0;i<10;i++)
        {
                vec.push_back(std::thread(Print10,i));
        }

        for(auto &th : vec)
        {
                if(th.joinable())
                        th.join();
        }

}

Answer 1

我相信下面的代码应该适合你

    #include<iostream>
    #include<vector>
    #include<thread>
    #include<mutex>
    #include<condition_variable>
    
    using namespace std;
    mutex mu;
    int count=1;
    bool isDone = true;
    condition_variable cv;
     
    void Print10(int tid)
    {
        unique_lock<std::mutex> lock(mu);
        
        // Wait until condition --> Wait till count/10 = tid
        while(count/10 != tid)
            cv.wait(lock);
        
        // Core logic 
        for(int i=0;i<10;i++)
            cout<<"tid="<<tid<<" count="<<count++<<"\n";
                
        // Release the current thread thus ensuring serailization
        cv.notify_one();
    }
    int main()
    {
        std::vector<std::thread> vec;
    
        for(int i=0;i<10;i++)
        {
            vec.push_back(std::thread(Print10,i));
        }
    
        for(auto &th : vec)
        {
            if(th.joinable())
                th.join();
        }
            
        return 0;
    }