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

Spout实现mk-threads接口用于建立与Executor对应的消息循环主函数。 defmulti mk-threads executor-selector数组 Mk-threads函数的主消息循环经过async-loop方法实现，若传入的函数为工厂方法，则在第一次调用该方法时进行初始化，并返回用于消息循环的函数。缓存 Spout输入处理函数async spout的输入处理函数采用非阻塞的方

>>阅读原文<<