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

问题来源

非常感谢@doctorwho的问题：

假如职业介绍所来了一批生产汽车的工作，假设生产一辆汽车任务是这样的：搭好底盘、拧4个轮胎、安装发动机、安装4个座椅、再装4个车门、最后安装顶棚。之间有的任务是可以并行计算的（比如拧4个轮胎，安装发动机和安装座椅），有的任务有前置任务（比如先装好座椅，才能装车门和顶棚）。让两组包工头组织两种类型的工作：将工人分成两种类型,即可并行计算的放在同一组内，由职业介绍所来控制A组包工头做完的任务交给B组包工头。中间环节的半成品保存到Warehouse中，是这样使用TINY框架来生产汽车么？

接下来，我就用Tiny并行计算框架来展示一下这个示例，在编写示例的时候，发现了一个BUG，这也充分体现了开源的精神与价值，再次感谢@doctorwho。

问题分析

doctorwho的问题还是比较复杂的，但是实际上道理是一样的，因此我把问题简化成下面的过程

第一步：构建底盘

第二步：并行进行安装引擎，座位和轮胎

第三步：并行进行安装门及车顶

由于我和doctorwho都不是造车行家，因此就不用纠结这么造是不是合理了，假设这么做就是合理的。

代码实现

按我前面说的过程，工人是必须要有的，因此我们首先构建工人：

第一步的底盘构建工人

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

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

第二步的座位工人：

第二步的轮胎工人：

同理，第三步也是大同小异的。

第三步的抽象工人类：

第三步的车门工人：

第三步的车顶工人：

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

第二部的任务分解：

从上面可以看到，构建了一个引擎的仓库，4个座位仓库，4个轮胎仓库。呵呵，既然能并行，为啥不让他做得更快些？

接下来是第三步的任务分解器：

从上面可以看到，第三部构建了4个门仓库一个车顶仓库，同样的，可以让4个工人同时装门。

上面就把所有的准备工作都做好了，接下来就是测试方法了：

呵呵，工人各加了5个，然后注册了三个工头，第一步的工头是随便挑一个工人类型的，第二步和第三步是挑所有工人的，同时还指定了任务分解器。

接下来就构建了一个工作，造一个高端大气上档次的普桑汽车，然后告诉职业介绍所说给我造就可以了。

下面是造车的过程，我把日志也贴上来了：

从上面的日志可以看出：

由于第一步工作是挑一个单干的，因此是没有启用线程组的

第二步同时有9个线程干活：

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

总结：

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