启动线程
"main" #1 prio=5 os_prio=0 tid=0x00007fedd400a000 nid=0x7acf in Object.wait() [0x00007fedddcbc000]
java.lang.Thread.State: WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
- waiting on <0x00000000c01730b0> (a java.lang.Thread)
at java.lang.Thread.join(Thread.java:1249)
- locked <0x00000000c01730b0> (a java.lang.Thread)
at java.lang.Thread.join(Thread.java:1323)
at com.alibaba.jstorm.callback.AsyncLoopThread.join(AsyncLoopThread.java:97)
at com.alibaba.jstorm.task.TaskShutdownDameon.join(TaskShutdownDameon.java:116)
at com.alibaba.jstorm.daemon.worker.WorkerShutdown.join(WorkerShutdown.java:160)
at com.alibaba.jstorm.daemon.worker.Worker.main(Worker.java:441)
Woker Main方法的线程。是Worker的启动线程，阻塞位置为
WorkerShutdown sd = mk_worker(conf, null, topology_id, supervisor_id, Integer.parseInt(port_str), worker_id, jar_path);
sd.join();//等待sd中的所有线程结束，结束后worker将被关闭
ZK相关
"ConnectionStateManager-0" #17 daemon prio=5 os_prio=0 tid=0x00007fedd43f1800 nid=0x7aee waiting on condition [0x00007fed94f75000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x00000000c032e688> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403)
at shade.storm.org.apache.curator.framework.state.ConnectionStateManager.processEvents(ConnectionStateManager.java:208)
at shade.storm.org.apache.curator.framework.state.ConnectionStateManager.access$000(ConnectionStateManager.java:42)
at shade.storm.org.apache.curator.framework.state.ConnectionStateManager$1.call(ConnectionStateManager.java:110)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Netty相关
包括一个server-boss，和若干个server-worker。