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

avatar
作者
猴君
阅读量:0

在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()唤醒所有等待的线程。一旦线程收到通知,它将重新获取互斥锁并继续执行。

广告一刻

为您即时展示最新活动产品广告消息,让您随时掌握产品活动新动态!