`

SlotsPipeline

 
阅读更多

SlotsPipeline 定义为一个管道。 可以向管道中推送对象和一个callback接口。

 

管道中有N个SlotsPipelineFilter,按SlotsPipelineFilter的先后顺序,依次对value对象管理,每次SlotsPipelineFilter处理完成后可能生成一个新的value或不变,再交由下一个SlotsPipelineFilter处理,直至所有SlotsPipelineFilter处理完成或出现异常时,调用callback接口通知处理完成或异常。

 




 
 

 



   SlotsPipelineFilter.intercept、exceptionCaught 方法是在线程池中被调用。

 

   SlotsPipelineFilter.intercept、exceptionCaught 方法需要主动调用以下方法中任意一个以完成事件顺序传递:

   1.SlotsPipeLineContext.fireCallBack 触发回调接口

   2.SlotsPipeLineContext.fireContinue 触发下一个Filter接口的intercept方法处理

   3.SlotsPipeLineContext.fireExceptionCaught 触发下一个Filter.exceptionCaught接口处理

 

 

  

  • 大小: 120.6 KB
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics