RedissonDelayedQueue源码解读

Posted 2023-03-19

参考技术A 这里使用了两个queue，对delayedQueue的offer操作是直接进入delayedQueue，元素到期之后进入blockingQueue，通过while循环取出到期的元素。

demo测试了延迟队列到期之后的延迟，结果比较震惊，达到了160s。分析发现，其实delayedQueue进入blockingQueue是准时的，但是同一时间到期的元素过多导致blockingQueue堆积，且只有一个线程消费blockingQueue,所以导致延迟越来越高；搞成两个线程消费延迟就正常到毫秒级了。