C++11 线程同步接口std::condition_variable和std::future的简单使用

std::condition_variable

条件变量std::condition_variable有wait和notify接口用于线程间的同步。如下图所示，Thread 2阻塞在wait接口，Thread 1通过notify接口通知Thread 2继续执行。

具体参见示例代码：

#include
#include
#include
#include
std::mutex mt;
std::queue data;
std::condition_variable cv;
auto start=std::chrono::high_resolution_clock::now();

void logCurrentTime()
{
	auto end = std::chrono::high_resolution_clock::now();
	auto elapsed = std::chrono::duration_cast<:chrono::milliseconds>(end - start).count();
	std::cout  lk(mt);
	//wait first for notification
	cv.wait(lk);  //it must accept a unique_lock parameter to wait

	while (!data.empty())
	{
		logCurrentTime();
		std::cout 

输出结果

分析

std::future

std::future与std::async配合异步执行代码，再通过wait或get接口阻塞当前线程等待结果。如下图所示，Thread 2中future接口的get或wait接口会阻塞当前线程，std::async异步开启的新线程Thread1执行结束后，将结果存于std::future后通知Thread 1获取结果后继续执行.

具体参见如下代码：

#include 
#include 
#include

int test()
{
	std::cout  result = std::async(test);

	std::cout 

输出结果

分析

主程序中调用std::async异步调用test函数，可以看到main函数的线程ID 27428与test函数执行的线程ID 9704并不一样，说明std::async另起了一个新的线程。在test线程中，先sleep 1000ms，所以可以看到”After lanuch a thread:”先输出，说明主线程异步执行，不受子线程影响。而”After get result “最后输出，说明get()方法会阻塞主线程，直到获取结果。