如何在C++中结合setevent实现线程同步

   2024-10-01 7690
核心提示:在C++中,可以使用std::condition_variable和std::mutex来实现线程同步#includeiostream#includethread#include mutex#includeco

在C++中,可以使用std::condition_variablestd::mutex来实现线程同步

#include<iostream>#include<thread>#include <mutex>#include<condition_variable>std::mutex mtx;std::condition_variable cv;bool ready = false;void print_id(int id) {    std::unique_lock<std::mutex> lck(mtx);    while (!ready) {  // 如果ready为false,则等待        cv.wait(lck);  // 当前线程被阻塞,等待条件变量被通知    }    // 现在线程继续执行    std::cout << "thread " << id << '\n';}void go() {    std::unique_lock<std::mutex> lck(mtx);    ready = true;  // 修改共享变量    cv.notify_all();  // 唤醒所有等待的线程}int main() {    std::thread threads[10];    // spawn 10 threads:    for (int i = 0; i < 10; ++i)        threads[i] = std::thread(print_id, i);    std::cout << "10 threads ready to race...\n";    go();  // go!    for (auto &th : threads) th.join();    return 0;}

在这个例子中,我们创建了10个线程,每个线程都会执行print_id函数。这些线程在开始时会获取互斥锁并检查ready变量。如果readyfalse,线程将调用cv.wait(lck)进入等待状态,此时线程会释放互斥锁并被阻塞。当go函数被调用时,ready变量被设置为true,并调用cv.notify_all()唤醒所有等待的线程。一旦线程收到通知,它将重新获取互斥锁并继续执行。

 
举报打赏
 
更多>同类维修大全
推荐图文
推荐维修大全
点击排行

网站首页  |  关于我们  |  联系方式网站留言    |  赣ICP备2021007278号