在多线程中,条件变量(condition variable)是一种用于线程间通信的机制。条件变量通常与互斥锁(mutex)一起使用,以实现对共享资源的线程安全访问。
在C++中,条件变量通常是通过std::condition_variable
类来实现的。条件变量主要用于线程之间的同步,常见的用法包括等待某个条件的发生或者通知其他线程条件的发生。
下面是一个简单的示例,演示了如何在多线程中使用条件变量:
#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
std::mutex mtx;
std::condition_variable cv;
bool ready = false;
void worker_thread() {
// 模拟一些工作
std::this_thread::sleep_for(std::chrono::seconds(1));
// 工作完成后通知主线程
{
std::lock_guard<std::mutex> lock(mtx);
ready = true;
}
cv.notify_one();
}
int main() {
std::thread worker(worker_thread);
// 等待工作完成
{
std::unique_lock<std::mutex> lock(mtx);
cv.wait(lock, []{ return ready; });
}
std::cout << "Work completed!" << std::endl;
worker.join();
return 0;
}
在上面的示例中,主线程等待工作线程完成工作,工作线程完成工作后通知主线程。主线程使用条件变量cv
和互斥锁mtx
来实现等待和通知的机制。