Storm Worker中的線程

worker中的每個計時器都對應一個java線程，使用計數器進行心跳保持以及獲取元數據更新信息。 創建woker  mk-worker函數用於創建worker進程，主要工作包括：   啓動相應計時器   創建worker中對應的executor   啓動接收消息線程   worker心跳信息  do-heartbeat函數用戶產生worker的心跳信息，這些信息被寫入本地文件系統中。 superv

>>阅读原文<<