### 使用c++11开发一个轻量级的并行task库
#### 15.1 TBB的基本用法
#### 15.1.1 TBB概述
TBB 是inter用标准c++写的一个开源的并行计算库，它的目的是提升数据并行计算的能力。主要功能如下：
1. 并行计算
2. 任务调度
3. 并行容器
4. 同步原语
5. 内存分配器
#### 15.1.2 TBB并行算法
1. parallel_for：以并行的方式遍历一个区间
2. parallel_do和parallel_for_each：将算法用于一个区间
3. parallel_reduce：并行汇聚
4. parallel_pipeline：并行的管道过滤器
5. parallel_sort和parallel_invoke：并行排序和调和
#### 15.1.3 TBB的任务组
```
tbb::task_group g;
g.run([]{task();});
g.run([]{task();});
g.run([]{task();});
g.wait();
```
#### 15.2 PPL的基本用法
两者差异：
1. parallel_reduce的原型有些不同。
2. PPL中没有parallel_pipeline接口
3. TBB的task没有PPL的task强大，PPL的task可以链式连续执行，还可以组合任务，而TBB的task不行。
#### 15.5 TaskCpp的任务
#### 15.5.1 task的实现
基于task的并行编程模型最基本的执行单元是task，一个task就代表了一个要执行的任务。外部只需要简单调用接口就可以创建task并且执行，另一个细节就是异步执行。
```
template<typename T>
	class Task;

	template<typename R, typename...Args>
	class Task<R(Args...)>
	{
		std::function<R(Args...)> m_fn;

	public:
		typedef R return_type;

		template<typename F>
		auto Then(F&& f)//->Task<typename std::result_of<F(R)>::type(Args...)>
		{
			typedef typename std::result_of<F(R)>::type ReturnType;
			auto func = std::move(m_fn);
			return Task<ReturnType(Args...)>([func, &f](Args&&... args)
			{
				std::future<R> lastf = std::async(func, std::forward<Args>(args)...);
				return std::async(f, lastf.get()).get();
			});
		}

		Task(std::function<R(Args...)>&& f) :m_fn(std::move(f)){}
		Task(std::function<R(Args...)>& f) :m_fn(f){}

		~Task()
		{
		}

		void Wait()
		{
			std::async(m_fn).wait();
		}

		template<typename... Args>
		R Get(Args&&... args)
		{
			return std::async(m_fn, std::forward<Args>(args)...).get();
		}

		std::shared_future<R> Run()
		{
			return std::async(m_fn);
		}
	};
```
#### 15.5.2 task的延续
```
#include <functional>
namespace Cosmos
{
	template<typename T>
	class Task;

	template<typename R, typename...Args>
	class Task<R(Args...)>
	{
		std::function<R(Args...)> m_fn;

	public:
		typedef R return_type;

		template<typename F>
		auto Then(F&& f)//->Task<typename std::result_of<F(R)>::type(Args...)>
		{
			typedef typename std::result_of<F(R)>::type ReturnType;
			auto func = std::move(m_fn);
			return Task<ReturnType(Args...)>([func, &f](Args&&... args)
			{
				std::future<R> lastf = std::async(func, std::forward<Args>(args)...);
				return std::async(f, lastf.get()).get();
			});
		}

		Task(std::function<R(Args...)>&& f) :m_fn(std::move(f)){}
		Task(std::function<R(Args...)>& f) :m_fn(f){}

		~Task()
		{
		}

		void Wait()
		{
			std::async(m_fn).wait();
		}

		template<typename... Args>
		R Get(Args&&... args)
		{
			return std::async(m_fn, std::forward<Args>(args)...).get();
		}

		std::shared_future<R> Run()
		{
			return std::async(m_fn);
		}
	};
}
```