美文网首页
storm源码工作流程(二)nimbus分配任务

storm源码工作流程(二)nimbus分配任务

作者: 小熊先生很不开心 | 来源:发表于2018-07-08 18:57 被阅读11次
clipboard17.png

接续上章 推送 任务到任务列表 这里的 用queue.put(event) 更好 因为是线程安全的 offer 不安全


clipboard18.png

这里的类 有一个方法会一直消费任务的 消费到任务字后对任务进行分配


clipboard19.png
clipboard20.png
点击进入 mkAssignment(event)方法
clipboard21.png
clipboard22.png

点击进入本地模式


clipboard23.png
worker的创建
clipboard24.png
map中会有一些 任务的相关信息 比如启动时间等
clipboard25.png
这个是 对任务信息进行记录
clipboard26.png
分配完成 返回 true

相关文章

网友评论

      本文标题:storm源码工作流程(二)nimbus分配任务

      本文链接:https://www.haomeiwen.com/subject/cloouftx.html