RpcStageController.java 文件源码

public RpcStageController(Long pipelineId){
    super(pipelineId);

    replys = OtterMigrateMap.makeComputingMap(new Function<StageType, ReplyProcessQueue>() {

        public ReplyProcessQueue apply(StageType input) {
            int size = ArbitrateConfigUtils.getParallelism(getPipelineId()) * 10;
            if (size < 100) {
                size = 100;
            }
            return new ReplyProcessQueue(size);
        }
    });

    progress = new MapMaker().makeMap();
    // 注册一下监听事件变化
    processMonitor = ArbitrateFactory.getInstance(pipelineId, ProcessMonitor.class);
    processMonitor.addListener(this);
    processMonitor.reload();
}