public class Pipeline<INPUT,OUTPUT> extends AbstractStage<INPUT,OUTPUT>
构造器和说明 |
---|
Pipeline(ExecutorService helperExecutor) |
限定符和类型 | 方法和说明 |
---|---|
<INPUT,OUTPUT> |
addExecutorForStage(Stage<INPUT,OUTPUT> stage,
ExecutorService executorService) |
OUTPUT |
doProcess(INPUT input) |
void |
init(PipelineContext context)
初始化各个Stage的关联关系(前后关系)。
|
void |
process(INPUT input) |
void |
shutdown() |
void |
shutdown(boolean isHalt)
关闭当前Pipeline.
|
setNextStage
public Pipeline(ExecutorService helperExecutor)
public void init(PipelineContext context)
public <INPUT,OUTPUT> void addExecutorForStage(Stage<INPUT,OUTPUT> stage, ExecutorService executorService)
public void process(INPUT input)
public OUTPUT doProcess(INPUT input) throws StageException
doProcess
在类中 AbstractStage<INPUT,OUTPUT>
StageException
public void shutdown()
public void shutdown(boolean isHalt)
isHalt:
- true代表需要关闭线程池资源,false代表不关闭。Copyright © 2019. All Rights Reserved.