ClassAbstractParallelPipe支持并行处理的Pipe实现类。 该类对其每个输入元素生成一组子任务,并以并行的方式去执行这些子任务。 各个子任务的执行结果会被合并为相应输入元素的输出结果。 @author Viscent Huang @param <IN> 输入类型 @param <OUT>
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/AbstractParallelPipe.java:36