在C++中,可以使用std::condition_variable
和std::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
变量。如果ready
为false
,线程将调用cv.wait(lck)
进入等待状态,此时线程会释放互斥锁并被阻塞。当go
函数被调用时,ready
变量被设置为true
,并调用cv.notify_all()
唤醒所有等待的线程。一旦线程收到通知,它将重新获取互斥锁并继续执行。