public class Pipeline<INPUT,OUTPUT> extends AbstractStage<INPUT,OUTPUT>
| Constructor and Description |
|---|
Pipeline(ExecutorService helperExecutor) |
| Modifier and Type | Method and Description |
|---|---|
<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.
|
setNextStagepublic 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 in class AbstractStage<INPUT,OUTPUT>StageExceptionpublic void shutdown()
public void shutdown(boolean isHalt)
isHalt: - true代表需要关闭线程池资源,false代表不关闭。Copyright © 2024. All Rights Reserved.