nettynetty HashedWheelTimer 延时队列

Posted 2022-01-30 九师兄

1.概述

想要研究这个是因为 【Flink】Flink 写入 Clickhouse 大对象直接进入老年代 导致OOM 遇到了这个问题。

在这个问题中，我将时间轮改小了 时间轮 512改成16个

Netty中提供的HashedWheelTimer时间轮算法的也是延迟队列一种。这个类用来计划执行非精准的I/O超时。

1.1 结构模型

下方图示阐述了大致的结构模型

2.类介绍

2.1 构造方法

    public