kafka 时间轮 tick 推进 为什么不用 delayQueue#take

[yanshenxian]

图片方框中的代码使用的是 bucket = delayQueue.poll(timeoutMs, TimeUnit.MILLISECONDS);

如果第一个即将到期的任务 >> 轮询的 timeoutMs, 这样不是会造成大量 cpu 空转吗

为什么不能用 bucket = delayQueue.take(); 呢

[yanshenxian]

关联代码 https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/utils/timer/Timer.scala

[mightofcode]

take 不能指定超时

[yanshenxian]

@mightofcode 这个不需要指定超时啊 时间轮只需要把过期的 task 取出来就行

[mightofcode]

@yanshenxian 不指定超时的话不就一直阻塞在这里了吗，看情况应该是不想阻塞在这吧

[yanshenxian]

@mightofcode 嗯 我觉得这里一直阻塞到有任务过期也是没问题的，换成 poll 也是相当于循环阻塞知道有任务过期

[hfc]

没有 CPU 空转吧，这里的 timeoutMs 时间内线程是 TIMEOUT_WATING 状态，不会占用 CPU 。超时没有获取到任务就返回 false 了。
至于为什么用 take，大概就是需要一个超时能自动结束的接口，翻翻代码或许也能找到使用 take 的接口，但是两者使用场景不同。