全部博文(403)
2012年(403)
分类: 嵌入式
2012-03-18 16:23:36
微软已经在VS10中加入了Concurrency Runtime namespace来支持C++的异步编程,笔者认为异步编程在是现代编程语言的一个发展方向。在此总结一些异步编程的基本概念和语法,希望能给大家理解异步编程带来一些方便。
首先,异步编程的基本单位是。我们把想要执行异步操作的函数放入task 里面,通过协调这些task的关系,来实现基于函数的异步操作。这种方式相对于传统的基于线程池的异步调用,开发者不需要关心底层的线程如何分配,资源如何同步,是否有死锁的存在。这样,开发者会更专注于代码的逻辑,进而提高编程的效率。
task
View Code
我们可以用.then()的方法去指定一个连续的任务,就是在前一个task完成之后立刻执行.then()里面的函数。这个函数要求接受前一个任务返回的结果。比如前一个任务中函数返回的是int 那么在.then()的函数里面就要指定传入参数为int的lambda表达式()[int res]{ res++;};。then()方法只要求传入参数和上一个任务相同,而返回值可以不同。比如下面的代码,第一个task返回int,在第一个then中返回void,然后返回int,最后返回void。这里要注意的是,在最后一个then()中调用wait,而不是t.wait(),否则第一个.then 不会执行。
task::then
这段代码展示的是如何嵌套task,注意这里的返回值虽然是task
nested task
一组task的执行,我们可以把一组task放入到容器里,然后通过when_all(),这个函数去执行他们,when_all传入参数是容器迭代器的开始和结束。这里要求容器里面的task的返回值必须相同。这是没有返回值的例子
Composing Tasks
这是有返回值的例子,注意when_all().then 的传入参数是vector
when_all return
when_all().wait()是当容器里面所有的task都被执行后,才继续向下执行。而when_any().wait()就是当容器里第一个task完成之后,就继续向下执行。和when_all 一样,when_any 要求task的返回值相同 。但是,when_any().then()的传入参数是pair
when_any
这篇文章是这个系列的第一篇,旨在向大家介绍一些基本的概念和用法。我会在接下来的系列中,给大家展示一些更深层次的东西。