往通道中存储一个“产品”。 @param product “产品” @throws InterruptedException

从通道中取出一个“产品”。 @return “产品” @throws InterruptedException

停止当前Pipe实例对外提供的服务。 @param timeout @param unit

用于Master向其提交一个子任务。 @param task 子任务 @return 可借以获取子任务处理结果的Promise（参见第6章，Promise模式）实例。 @throws InterruptedException

对输入元素进行处理，并将处理结果作为下一个Pipe实例的输入。

初始化当前Pipe实例对外提供的服务。 @param pipeCtx

发送告警 @param type 告警类型 @param id 告警编号 @param extraInfo 告警参数 @return 由type+id+extraInfo唯一确定的告警信息被提交的次数。-1表示告警管理器已被关闭。

生成并下发验证码短信到指定的手机号码。 @param msisdn 短信接收方号码。

设置当前Pipe实例的下一个Pipe实例。 @param nextPipe 下一个Pipe实例

在保护条件成立时执行目标动作，否则阻塞当前线程，直到保护条件成立。 @param guardedAction 带保护条件的目标动作 @return @throws Exception

根据指定的原始任务分解策略，将分解得来的各个子任务派发给一组Slave参与者实例。 @param slaves 可以接受子任务的一组Slave参与者实例 @param taskDivideStrategy 原始任务分解策略 @return iterato

留给子类实现。用于实现子任务的处理逻辑。 @param task 子任务 @return 子任务的处理结果 @throws Exception

用于对处理阶段抛出的异常进行处理. @param exp

初始化Slave实例提供的服务

执行stateOperation所指定的操作后，决定是否唤醒本Blocker所暂挂的所有线程中的一个线程。 @param stateOperation 更改状态的操作，其call方法的返回值为true时，该方法才会唤醒被暂挂的线程

留给子类实现。用于根据指定的输入元素input构造一组子任务。 @param input 输入元素 @param <V> 子任务的处理结果类型 @return 一组子任务

留给子类实现。用于合并子任务的处理结果。 @param subResults 各个子任务处理结果 @return 原始任务的处理结果

留给子类实现。对各个子任务的处理结果进行合并，形成相应输入元素的输出结果。 @param subTaskResults 子任务处理结果列表 @return 相应输入元素的处理结果 @throws Exception