手写中间件之——并行框架(2 任务编排顺序如何选型和实现)

2020-01-13 15:54:56 浏览数 (1)

这一篇我们就要开始手写这个并行框架了。

做任何一个项目,都要做的事情都是先定大框架,后拆解任务。

那么这个并发框架,要完成上一篇讲的那些所有任务,该如何定大框架呢,如何选型呢?

如果大家仔细看了上一篇文章,可以看到该框架的难点和重点,主要有两点,分别是任务的顺序编排任务结果的回调。

如何做任务顺序编排

依次来看一下各个基本场景

1 全串行

这种是最简单的,依次串行即可。

假如有3个任务,譬如每个任务由一个worker来完成,共计3个worker,这3个worker有明显的先后顺序。要描述这种依赖关系和前后顺序,我们对任务的包装类应该至少有两个属性,nextWrappers和dependWrappers。分别代表我这个任务的后面的任务和依赖的任务。

以B为例,nextWrapper就是C,dependWrapper就是A。

2 全并行

这种也很简单,也比较常见。全并行的实现方式很多,譬如可以将所有的worker放到list里,写个for循环依次start;也可以全部提交到线程池里;也可以用CompleteableFuture.supply()去接收多个worker任务。

3 先串后并

0 人点赞