这一篇我们就要开始手写这个并行框架了。
做任何一个项目,都要做的事情都是先定大框架,后拆解任务。
那么这个并发框架,要完成上一篇讲的那些所有任务,该如何定大框架呢,如何选型呢?
如果大家仔细看了上一篇文章,可以看到该框架的难点和重点,主要有两点,分别是任务的顺序编排和任务结果的回调。
如何做任务顺序编排
依次来看一下各个基本场景
1 全串行
这种是最简单的,依次串行即可。
假如有3个任务,譬如每个任务由一个worker来完成,共计3个worker,这3个worker有明显的先后顺序。要描述这种依赖关系和前后顺序,我们对任务的包装类应该至少有两个属性,nextWrappers和dependWrappers。分别代表我这个任务的后面的任务和依赖的任务。
以B为例,nextWrapper就是C,dependWrapper就是A。
2 全并行
这种也很简单,也比较常见。全并行的实现方式很多,譬如可以将所有的worker放到list里,写个for循环依次start;也可以全部提交到线程池里;也可以用CompleteableFuture.supply()去接收多个worker任务。
3 先串后并