一、std::promise介紹

#include <iostream>
#include <future>
#include <chrono>

void Thread_Fun1(std::promise<int> &p)
{
	//為了突出效果，可以使執行緒休眠5s
	std::this_thread::sleep_for(std::chrono::seconds(5));

	int iVal = 233;
	std::cout << "傳入資料(int)：" << iVal << std::endl;

	//傳入資料iVal
	p.set_value(iVal);
}

void Thread_Fun2(std::future<int> &f)
{
	//阻塞函式，直到收到相關聯的std::promise物件傳入的資料
	auto iVal = f.get();		//iVal = 233

	std::cout << "收到資料(int)：" << iVal << std::endl;
}

int main()
{
	//宣告一個std::promise物件pr1，其儲存的值型別為int
	std::promise<int> pr1;
	//宣告一個std::future物件fu1，並通過std::promise的get_future()函式與pr1繫結
	std::future<int> fu1 = pr1.get_future();

	//建立一個執行緒t1，將函式Thread_Fun1及物件pr1放線上程裡面執行
	std::thread t1(Thread_Fun1, std::ref(pr1));
	//建立一個執行緒t2，將函式Thread_Fun2及物件fu1放線上程裡面執行
	std::thread t2(Thread_Fun2, std::ref(fu1));

	//阻塞至執行緒結束
	t1.join();
	t2.join();

	return 1;
}
 

#include <iostream>
#include <future>
#include <chrono>
#include <functional>

//宣告一個可調物件T
using T = std::function<int(int)>;		//等同於typedef std::function<int(int)> T;

int Test_Fun(int iVal)
{
	std::cout << "Value is:" << iVal << std::endl;
	return iVal + 232;
}

void Thread_Fun1(std::promise<T> &p)
{
	//為了突出效果，可以使執行緒休眠5s
	std::this_thread::sleep_for(std::chrono::seconds(5));

	std::cout << "傳入函式Test_Fun" << std::endl;

	//傳入函式Test_Fun
	p.set_value(std::bind(&Test_Fun, std::placeholders::_1));
}

void Thread_Fun2(std::future<T> &f)
{
	//阻塞函式，直到收到相關聯的std::promise物件傳入的資料
	auto fun = f.get();		//iVal = 233

	int iVal = fun(1);

	std::cout << "收到函式並執行，結果：" << iVal << std::endl;
}

int main()
{
	//宣告一個std::promise物件pr1，其儲存的值型別為int
	std::promise<T> pr1;
	//宣告一個std::future物件fu1，並通過std::promise的get_future()函式與pr1繫結
	std::future<T> fu1 = pr1.get_future();

	//建立一個執行緒t1，將函式Thread_Fun1及物件pr1放線上程裡面執行
	std::thread t1(Thread_Fun1, std::ref(pr1));
	//建立一個執行緒t2，將函式Thread_Fun2及物件fu1放線上程裡面執行
	std::thread t2(Thread_Fun2, std::ref(fu1));

	//阻塞至執行緒結束
	t1.join();
	t2.join();

	return 1;
}
 

#include <iostream>
#include <future>
#include <chrono>
#include <functional>

//宣告一個可調物件F
using F = std::function<int(int, int, int&)>;		//等同於typedef std::function<int(int, int, int&)> F;

//函式可以改成任意引數，任意返回型別
int Test_Fun(int a, int b, int &c)
{
	//a = 1, b = 2
	c = a + b + 230;
	return c;
}

void Thread_Fun1(std::promise<F> &p)
{
	//為了突出效果，可以使執行緒休眠5s
	std::this_thread::sleep_for(std::chrono::seconds(5));

	std::cout << "傳入函式Test_Fun" << std::endl;

	//傳入函式Test_Fun
	p.set_value(std::bind(&Test_Fun, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3));
}

template<typename T, typename ...Args>
void Thread_Fun2(std::future<T> &f, Args&& ...args)
{
	//阻塞函式，直到收到相關聯的std::promise物件傳入的資料
	auto fun = f.get();		//fun等同於Test_Fun

	auto fResult = fun(std::forward<Args>(args)...);

	std::cout << "收到函式並執行，結果：" << fResult << std::endl;
}

int main()
{
	//宣告一個std::promise物件pr1，其儲存的值型別為int
	std::promise<F> pr1;
	//宣告一個std::future物件fu1，並通過std::promise的get_future()函式與pr1繫結
	std::future<F> fu1 = pr1.get_future();

	//宣告一個變數
	int iVal = 0;

	//建立一個執行緒t1，將函式Thread_Fun1及物件pr1放線上程裡面執行
	std::thread t1(Thread_Fun1, std::ref(pr1));
	//建立一個執行緒t2，將函式Thread_Fun2及物件fu1放線上程裡面執行
	std::thread t2(Thread_Fun2<F, int, int, int&>, std::ref(fu1), 1, 2, std::ref(iVal));

	//阻塞至執行緒結束
	t1.join();
	t2.join();

	//此時iVal的值變成233

	return 1;
}