storm源码工作流程（二）nimbus分配任务

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
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容

  • iOS 面试宝典 没有比这更全的了（持续更新）
    1.ios高性能编程 (1).内层 最小的内层平均值和峰值(2).耗电量 高效的算法和数据结构(3).初始化时...
    欧辰_OSR阅读 29,876评论 8赞 265
  • Spring Cloud
    Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智...
    卡卡罗2017阅读 135,739评论 19赞 139
  • OC&iOS
    OC语言基础 1.类与对象 类方法 OC的类方法只有2种：静态方法和实例方法两种 在OC中，只要方法声明在@int...
    奇异果好补阅读 9,802评论 0赞 11
  • Java-Review-Note——4.多线程
    Java-Review-Note——4.多线程 标签： JavaStudy PS：本来是分开三篇的，后来想想还是整...
    coder_pig阅读 5,595评论 2赞 17
  • 自残，缺爱，冷酷三部曲
    很长时间没写东西了吧，写点心情记录。 自从新学期开学，我的心似乎总被某种负面情绪所占据， 开学两星期，正常上课，我...
    击空留影阅读 3,465评论 1赞 0