async()
async()函数是一个简单任务的”启动”(launcher)函数,它是本FAQ中唯一一个尚未在标准草案中投票通过的特性。我希望它能在调和两个略微不同的意见之后最终于10月份获得通过(记得随时骚扰你那边的投票委员,一定要为它投票啊?)。
下边是一种优于传统的线程+锁的并发编程方法示例(译注:山寨map-reduce哦):
template<class T,class V> struct Accum { // 简单的积函数对象
T* b;
T* e;
V val;
Accum(T* bb, T* ee, const V& v) : b{bb}, e{ee}, val{vv} {}
V operator() ()
{ return std::accumulate(b,e,val); }
};
void comp(vector<double>& v)
// 如果v够大,则产生很多任务 {
if (v.size()<10000)
return std::accumulate(v.begin(),v.end(),0.0);
auto f0 {async(Accum{&v[0],&v[v.size()/4],0.0})};
auto f1 {async(Accum{&v[v.size()/4],&v[v.size()/2],0.0})};
auto f2 {async(Accum{&v[v.size()/2],&v[v.size()*3/4],0.0})};
auto f3 {async(Accum{&v[v.size()*3/4],&v[v.size()],0.0})};
return f0.get()+f1.get()+f2.get()+f3.get();
}
尽管这只是一个简单的并发编程示例(留意其中的”magic number“),不过我们可没有使用线程,锁,缓冲区等概念。f*变量的类型(即async()的返回值)是”std::future”类型。future.get()表示如果有必要的话则等待相应的线程(std::thread)运行结束。async的工作是根据需要来启动新线程,而future的工作则是等待新线程运行结束。”简单性”是async/future设计中最重视的一个方面;future一般也可以和线程一起使用,不过不要使用async()来启动类似I/O操作,操作互斥体(mutex),多任务交互操作等复杂任务。async()背后的理念和range-for statement很类似:简单事儿简单做,把复杂的事情留给一般的通用机制来搞定吧。
async()可以启动一个新线程或者复用一个它认为合适的已有线程(非调用线程即可)(译注:语义上并发即可,不关心具体的调度策略。和go语义中的goroutines有点像)。后者从用户视角看更有效一些(只对简单任务而言)。
参考:
- Standard: ???
Lawrence Crowl:
N2889 = 09-0079.
Herb Sutter :
N2901 = 09-0091 .
(翻译:interma)