kafka TimingWheel(时间轮)

先吐个槽,不喜勿喷,最近非常想换工作,在目前这家公司待的还不满一年,为什么想离职呢?年前加了半年的班几乎每天都是九点多才下班,有时候周末也要来,但是很少有人有年终,大部分就是12薪,mmp,这时候肯定想走,但是还是想待满一年之后,想换工作的直接导火索,年前公司分产品线,被别的部门领导给选了过去,直接上司呢是个傻逼,什么都不会就知道瞎逼逼,给别人说话很不耐烦的,为什么能当上领导和上级关系好呗!这时候要么忍要么滚,所以就打算滚了,目前公司很多人在找工作。。。

上篇文章说到HashedWheelTimer结构是个数组+链表,而kafka TimingWheel结构也是个数组+链表,区别呢HashedWheelTimer只有一个轮(一个数组),而TimingWheel是多轮(多数组)。TimingWheel结构是由DelayQueue(这个实质上是object数组,最外层的轮)+buckets(数组+TimerTaskList)组成,如下图


kafka TimingWheel源码解析也是一坨,不多说这个了,想说下kafka和netty时间轮的一些区别,kafka的时间轮获取下一轮时间数据采用了DelayQueue.poll(timeoutMs, TimeUnit.MILLISECONDS)(这个源码在Timer.advanceClock),这样做的优点当有数据加入到这一轮的时候直接获取数据即可,而netty HashedWheelTimer采用的是sleep,当有数据加入到这一轮的时候,它会自动把数据加入到下一个数组内,而不是唤醒,唤醒可能会出问题,相对有一定延时。kafka TimingWheel多数组(多轮),netty HashedWheelTimer单数组(一轮),假如有多轮数据的时候,netty会把多轮的数据给个标识加入到单轮的链表里,造成不便的遍历。如下图


最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

  • 零、时间轮定义 简单说说时间轮吧,它是一个高效的延时队列,或者说定时器。实际上现在网上对于时间轮算法的解释很多,定...
    Java大生阅读 5,931评论 1 0
  • 概述 这篇博文的起源在于阿里的公众号里面有一篇文章讲菜鸟的同学在造一个关于时间轮定时器的文章,然后在网上搜索资...
    晴天哥_王志阅读 12,396评论 3 7
  • kafka的定义:是一个分布式消息系统,由LinkedIn使用Scala编写,用作LinkedIn的活动流(Act...
    时待吾阅读 10,784评论 1 15
  • 时间轮 Kafka中存在大量的延迟操作,比如延迟生产,延迟拉取,延迟加入,延迟心跳等。kafka使用时间轮(Tim...
    绍圣阅读 5,123评论 0 0
  • 零时,醒着但没有醒来 灵魂执拗的游走在梦与幻之间 夜很静,静的可以听到静的 脚步不紧不慢地走在时钟表面...
    改变自己369阅读 2,695评论 0 4

友情链接更多精彩内容