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

c++
567
2024/8/27 15:30:53
栏目: 编程语言
开发者测试专用服务器限时活动,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()唤醒所有等待的线程。一旦线程收到通知,它将重新获取互斥锁并继续执行。

辰迅云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>

推荐阅读: c++中yield函数的用法是什么