kafka TimingWheel(時(shí)間輪)

先吐個(gè)槽战转,不喜勿噴搜立,最近非常想換工作,在目前這家公司待的還不滿一年槐秧,為什么想離職呢儒拂?年前加了半年的班幾乎每天都是九點(diǎn)多才下班,有時(shí)候周末也要來(lái)色鸳,但是很少有人有年終社痛,大部分就是12薪,mmp命雀,這時(shí)候肯定想走蒜哀,但是還是想待滿一年之后,想換工作的直接導(dǎo)火索,年前公司分產(chǎn)品線撵儿,被別的部門領(lǐng)導(dǎo)給選了過(guò)去乘客,直接上司呢是個(gè)傻逼,什么都不會(huì)就知道瞎逼逼淀歇,給別人說(shuō)話很不耐煩的易核,為什么能當(dāng)上領(lǐng)導(dǎo)和上級(jí)關(guān)系好唄!這時(shí)候要么忍要么滾浪默,所以就打算滾了牡直,目前公司很多人在找工作。纳决。碰逸。

上篇文章說(shuō)到HashedWheelTimer結(jié)構(gòu)是個(gè)數(shù)組+鏈表,而kafka TimingWheel結(jié)構(gòu)也是個(gè)數(shù)組+鏈表阔加,區(qū)別呢HashedWheelTimer只有一個(gè)輪(一個(gè)數(shù)組)饵史,而TimingWheel是多輪(多數(shù)組)。TimingWheel結(jié)構(gòu)是由DelayQueue(這個(gè)實(shí)質(zhì)上是object數(shù)組胜榔,最外層的輪)+buckets(數(shù)組+TimerTaskList)組成胳喷,如下圖


kafka?TimingWheel源碼解析也是一坨,不多說(shuō)這個(gè)了夭织,想說(shuō)下kafka和netty時(shí)間輪的一些區(qū)別厌蔽,kafka的時(shí)間輪獲取下一輪時(shí)間數(shù)據(jù)采用了DelayQueue.poll(timeoutMs, TimeUnit.MILLISECONDS)(這個(gè)源碼在Timer.advanceClock),這樣做的優(yōu)點(diǎn)當(dāng)有數(shù)據(jù)加入到這一輪的時(shí)候直接獲取數(shù)據(jù)即可,而netty?HashedWheelTimer采用的是sleep摔癣,當(dāng)有數(shù)據(jù)加入到這一輪的時(shí)候奴饮,它會(huì)自動(dòng)把數(shù)據(jù)加入到下一個(gè)數(shù)組內(nèi),而不是喚醒择浊,喚醒可能會(huì)出問(wèn)題戴卜,相對(duì)有一定延時(shí)。kafka?TimingWheel多數(shù)組(多輪)琢岩,netty?HashedWheelTimer單數(shù)組(一輪)投剥,假如有多輪數(shù)據(jù)的時(shí)候,netty會(huì)把多輪的數(shù)據(jù)給個(gè)標(biāo)識(shí)加入到單輪的鏈表里担孔,造成不便的遍歷江锨。如下圖


最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市糕篇,隨后出現(xiàn)的幾起案子啄育,更是在濱河造成了極大的恐慌,老刑警劉巖拌消,帶你破解...
    沈念sama閱讀 217,277評(píng)論 6 503
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件挑豌,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡,警方通過(guò)查閱死者的電腦和手機(jī)氓英,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,689評(píng)論 3 393
  • 文/潘曉璐 我一進(jìn)店門侯勉,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái),“玉大人铝阐,你說(shuō)我怎么就攤上這事址貌。” “怎么了徘键?”我有些...
    開(kāi)封第一講書(shū)人閱讀 163,624評(píng)論 0 353
  • 文/不壞的土叔 我叫張陵练对,是天一觀的道長(zhǎng)。 經(jīng)常有香客問(wèn)我啊鸭,道長(zhǎng)锹淌,這世上最難降的妖魔是什么匿值? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 58,356評(píng)論 1 293
  • 正文 為了忘掉前任赠制,我火速辦了婚禮,結(jié)果婚禮上挟憔,老公的妹妹穿的比我還像新娘钟些。我一直安慰自己,他們只是感情好绊谭,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,402評(píng)論 6 392
  • 文/花漫 我一把揭開(kāi)白布政恍。 她就那樣靜靜地躺著,像睡著了一般达传。 火紅的嫁衣襯著肌膚如雪篙耗。 梳的紋絲不亂的頭發(fā)上,一...
    開(kāi)封第一講書(shū)人閱讀 51,292評(píng)論 1 301
  • 那天宪赶,我揣著相機(jī)與錄音宗弯,去河邊找鬼。 笑死搂妻,一個(gè)胖子當(dāng)著我的面吹牛蒙保,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播欲主,決...
    沈念sama閱讀 40,135評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼邓厕,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼!你這毒婦竟也來(lái)了扁瓢?” 一聲冷哼從身側(cè)響起详恼,我...
    開(kāi)封第一講書(shū)人閱讀 38,992評(píng)論 0 275
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎引几,沒(méi)想到半個(gè)月后单雾,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,429評(píng)論 1 314
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,636評(píng)論 3 334
  • 正文 我和宋清朗相戀三年硅堆,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了屿储。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,785評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡渐逃,死狀恐怖够掠,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情茄菊,我是刑警寧澤疯潭,帶...
    沈念sama閱讀 35,492評(píng)論 5 345
  • 正文 年R本政府宣布,位于F島的核電站面殖,受9級(jí)特大地震影響竖哩,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜脊僚,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,092評(píng)論 3 328
  • 文/蒙蒙 一相叁、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧辽幌,春花似錦增淹、人聲如沸。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 31,723評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)。三九已至加酵,卻和暖如春拳喻,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背猪腕。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 32,858評(píng)論 1 269
  • 我被黑心中介騙來(lái)泰國(guó)打工冗澈, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人码撰。 一個(gè)月前我還...
    沈念sama閱讀 47,891評(píng)論 2 370
  • 正文 我出身青樓渗柿,卻偏偏與公主長(zhǎng)得像,于是被迫代替她去往敵國(guó)和親脖岛。 傳聞我的和親對(duì)象是個(gè)殘疾皇子朵栖,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,713評(píng)論 2 354

推薦閱讀更多精彩內(nèi)容

  • 零、時(shí)間輪定義 簡(jiǎn)單說(shuō)說(shuō)時(shí)間輪吧柴梆,它是一個(gè)高效的延時(shí)隊(duì)列陨溅,或者說(shuō)定時(shí)器。實(shí)際上現(xiàn)在網(wǎng)上對(duì)于時(shí)間輪算法的解釋很多绍在,定...
    Java大生閱讀 1,950評(píng)論 1 0
  • 概述 這篇博文的起源在于阿里的公眾號(hào)里面有一篇文章講菜鳥(niǎo)的同學(xué)在造一個(gè)關(guān)于時(shí)間輪定時(shí)器的文章门扇,然后在網(wǎng)上搜索資...
    晴天哥_王志閱讀 7,781評(píng)論 3 7
  • kafka的定義:是一個(gè)分布式消息系統(tǒng)雹有,由LinkedIn使用Scala編寫,用作LinkedIn的活動(dòng)流(Act...
    時(shí)待吾閱讀 5,317評(píng)論 1 15
  • 時(shí)間輪 Kafka中存在大量的延遲操作臼寄,比如延遲生產(chǎn)霸奕,延遲拉取,延遲加入吉拳,延遲心跳等质帅。kafka使用時(shí)間輪(Tim...
    紹圣閱讀 1,297評(píng)論 0 0
  • 零時(shí),醒著但沒(méi)有醒來(lái) 靈魂執(zhí)拗的游走在夢(mèng)與幻之間 夜很靜留攒,靜的可以聽(tīng)到靜的 腳步不緊不慢地走在時(shí)鐘表面...
    改變自己369閱讀 339評(píng)論 0 4