#include <iostream> // std::cout
#include <thread> // std::thread
#include <chrono> // std::chrono::seconds
#include <mutex> // std::mutex, std::unique_lock
#include <condition_variable> // std::condition_variable, std::cv_status
std::mutex mtx;
std::condition_variable cv;
int value;
void do_read_value()
{
std::this_thread::sleep_for(std::chrono::seconds(5));
cv.notify_one();
}
int main()
{
std::cout << "Please, enter an integer (I'll be printing dots): \n";
std::thread th(do_read_value);
std::unique_lock<std::mutex> lck(mtx);
std::cout << "main pid: " << std::this_thread::get_id() << std::endl;
//最后一个参数是预制条件,调用wait_for的时候,首先就会判断这个条件,
//如果这个条件返回false,那么会继续等待,如果再超时之前,收到了一个notify
//那么他会再次执行这个预制条件来进行判断,超时的时候也还会再此执行这个条件,
//条件成立就不会再进行等待
//这种可以用在处理队列事件
cv.wait_for(lck, std::chrono::seconds(20), [] {
std::cout << "begin cPid:" <<std::this_thread::get_id()<< std::endl;
std::this_thread::sleep_for(std::chrono::seconds(1));
std::cout << "end" << std::endl;
return false;
});
std::cout << "aaaaaaaaa" << std::endl;
std::cout << "You entered: " << value << '\n';
std::this_thread::sleep_for(std::chrono::seconds(100));
//th.join();
return 0;
}