Storm系列(十五)架構分析之Executor-Spout

Spout實現mk-threads接口用於建立與Executor對應的消息循環主函數。 defmulti mk-threads executor-selector數組 Mk-threads函數的主消息循環經過async-loop方法實現，若傳入的函數爲工廠方法，則在第一次調用該方法時進行初始化，並返回用於消息循環的函數。緩存 Spout輸入處理函數async spout的輸入處理函數採用非阻塞的方

>>阅读原文<<