topology中执行所有组件的总线程数为4+4+2=10个 ----worker数量是4个,有可能会出现这样的负载情况,worker-1有2个线程,worker-2有2个线程,worker-3有3个线程,worker
topology中执行所有组件的总线程数为4+4+2=10个 ----worker数量是4个,有可能会出现这样的负载情况,worker-1有2个线程,worker-2有2个线程,worker-3有3个线程,worker
方法启动一个线程, 当这个线程的逻辑执行完毕的时候,线程自动退出, Python 没有提供主动退出线程的方法 # 输出以下结果 worker-0worker-1worker-2worker-3 worker 2017-03-20 21:39:29,340 INFO [workerthread-3] worker-3 2017-03-20 21:39:29,346 INFO [workerthread-4] worker INFO [worker-1] sleep 3 2017-03-21 21:20:17,199 INFO [worker-3] sleep 2 2017-03-21 21:20:17,198 INFO [worker
Thread:Worker-0,value:0 Thread:Worker-3,value:3 Thread:Worker-2,value:2 Thread:Worker-1,value:1 Thread:Worker -4,value:4 Thread:Worker-1,value:5 Thread:Worker-2,value:8 Thread:Worker-4,value:7 Thread:Worker-0,value
0 3d16h 10.100.79.96 k8s-worker-4 <none> <none> [root@k8s-master-2 ~]# 在worker
2017-10-23 23:21:58.125 :天气数据同步任务 job .WeatherDataSyncJob 2017-10-23 23:22:00.117 INEO 8440---[eduler Worker
Thread:Worker-0,value:0 Thread:Worker-3,value:3 Thread:Worker-2,value:2 Thread:Worker-1,value:1 Thread:Worker -4,value:4 Thread:Worker-1,value:5 Thread:Worker-2,value:8 Thread:Worker-4,value:7 Thread:Worker-0,value
42,116 INFO worker-2 sleep 4 2017-09-25 06:15:42,116 INFO worker-3 sleep 3 2017-09-25 06:15:42,117 INFO worker