Storm Worker中的线程

worker中的每个计时器都对应一个java线程，使用计数器进行心跳保持以及获取元数据更新信息。 创建woker  mk-worker函数用于创建worker进程，主要工作包括：   启动相应计时器   创建worker中对应的executor   启动接收消息线程   worker心跳信息  do-heartbeat函数用户产生worker的心跳信息，这些信息被写入本地文件系统中。 superv

>>阅读原文<<