Tiny并行计算框架之复杂示例

标签：

问题来源  非常感谢@doctorwho的问题： 
假如职业介绍所来了一批生产汽车的工作，假设生产一辆汽车任务是这样的：搭好底盘、拧4个轮胎、安装发动机、安装4个座椅、再装4个车门、最后安装顶棚。之间有的任务是可以并行计算的（比如拧4个轮胎，安装发动机和安装座椅），有的任务有前置任务（比如先装好座椅，才能装车门和顶棚）。让两组包工头组织两种类型的工作：将工人分成两种类型,即可并行计算的放在同一组内，由职业介绍所来控制A组包工头做完的任务交给B组包工头。中间环节的半成品保存到Warehouse中，是这样使用TINY框架来生产汽车么？
接下来，我就用Tiny并行计算框架来展示一下这个示例，在编写示例的时候，发现了一个BUG，这也充分体现了开源的精神与价值，再次感谢@doctorwho。 
问题分析 
doctorwho的问题还是比较复杂的，但是实际上道理是一样的，因此我把问题简化成下面的过程 
第一步：构建底盘 
第二步：并行进行安装引擎，座位和轮胎

第三步：并行进行安装门及车顶 
由于我和doctorwho都不是造车行家，因此就不用纠结这么造是不是合理了，假设这么做就是合理的。 
代码实现 
按我前面说的过程，工人是必须要有的，因此我们首先构建工人： 
第一步的底盘构建工人 

由于第二步工人有好几个类型，因此再搞个第二步抽象工人： 

接下来构建第二步的引擎工人： 

第二步的座位工人： 

第二步的轮胎工人： 

?

同理，第三步也是大同小异的。 
第三步的抽象工人类： 

第三步的车门工人： 

第三步的车顶工人： 

以上就把工人都构建好了，我们前面也说过，如果要进行任务分解，是必须要构建任务分解合并器的，这里简单起见，只实现任务分解了。 
第二部的任务分解： 

从上面可以看到，构建了一个引擎的仓库，4个座位仓库，4个轮胎仓库。呵呵，既然能并行，为啥不让他做得更快些？ 
接下来是第三步的任务分解器： 

从上面可以看到，第三部构建了4个门仓库一个车顶仓库，同样的，可以让4个工人同时装门。 
上面就把所有的准备工作都做好了，接下来就是测试方法了： 

呵呵，工人各加了5个，然后注册了三个工头，第一步的工头是随便挑一个工人类型的，第二步和第三步是挑所有工人的，同时还指定了任务分解器。 
接下来就构建了一个工作，造一个高端大气上档次的普桑汽车，然后告诉职业介绍所说给我造就可以了。 
下面是造车的过程，我把日志也贴上来了： 

从上面的日志可以看出： 
由于第一步工作是挑一个单干的，因此是没有启用线程组的 
第二步同时有9个线程干活： 

第三步同时有5个线程干活： 

总结： 
Tiny并行计算框架确实是可以方便的解决各种复杂并行计算的问题。

Tiny并行计算框架之复杂示例

标签：

原文地址：http://www.cnblogs.com/j2eetop/p/4612481.html