JStorm源代碼閱讀-bolt/spout的執行

無論是bolt還是spout，線程使用Runnable對象都是AsyncLoopRunnable public class AsyncLoopRunnable implements Runnable { private RunnableCallback fn;//RunnableCallback implements Runnable, Callback, Shutdownable，實際執行的e

>>阅读原文<<