|
std::condition_variable是条件变量，当?std::condition_variable对象的某个wait?函数被调用的时候，它使用?std::unique_lock(通过?std::mutex) 来锁住当前线程。当前线程会一直被阻塞，直到另外一个线程在相同的?std::condition_variable?对象上调用了?notification?函数来唤醒当前线程。
#include <thread>
#include <iostream>
#include <mutex>
#include <condition_variable>
std::mutex data_mutex;
std::condition_variable data_var;
int flag=1;
int i=0;
#define MAXNUM 100
void printA(){
while(i<MAXNUM){
// std::this_thread::sleep_for(std::chrono::seconds(1)); //打印节奏变慢
std::unique_lock<std::mutex> lck(data_mutex);
//当flag为1时，wait不阻塞；否则wait阻塞当前线程。
//允许其他锁住的线程继续，当其他线程调用notify函数后，并且flag为1时
//此线程被唤醒
data_var.wait(lck, []{return flag==1;});
flag=2;
if(i >= 100){
data_var.notify_all();
break;
}
i++;
std::cout<<"threadA:"<<i<<std::endl;
data_var.notify_all();
}
std::cout<<"finish A"<<std::endl;
}
void printB(){
while(i<MAXNUM){
std::unique_lock<std::mutex> lck(data_mutex);
//当flag为2时，wait不阻塞；否则wait阻塞当前线程。
//允许其他锁住的线程继续，当其他线程调用notify函数后，并且flag为2时
//此线程被唤醒
data_var.wait(lck, []{return flag==2;});
flag = 3;
if(i >= 100){
data_var.notify_all();
break;
}
i++;
std::cout<<"threadB:"<<i<<std::endl;
data_var.notify_all();
}
std::cout<<"finish B"<<std::endl;
}
void printC(){
while(i<MAXNUM){
std::unique_lock<std::mutex> lck(data_mutex);
//当flag为3时，wait不阻塞；否则wait阻塞当前线程。
//允许其他锁住的线程继续，当其他线程调用notify函数后，并且flag为3时
//此线程被唤醒
data_var.wait(lck, []{return flag==3;});
flag = 1;
if(i >= 100){
data_var.notify_all();
break;
}
i++;
std::cout<<"threadC:"<<i<<std::endl;
data_var.notify_all();
}
std::cout<<"finish C"<<std::endl;
}
int main(){
std::thread tA(printA);
std::thread tB(printB);
std::thread tC(printC);
tA.join();
tB.join();
tC.join();
std::cout << i << std::endl;//最后验证i是否严格等于100
system("pause");
return 0;
}
打印结果：
...前面的93个打印行省略不写了
threadA:94
threadB:95
threadC:96
threadA:97
threadB:98
threadC:99
threadA:100
finish A
finish C
finish B
100
请按任意键继续. . .
|