[代码讨论]在均匀分布的消息逻辑中使用线程局部变量？

rocketmq/client/src/main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java

Lines 23 to 35 in 81e3648

private final ThreadLocal threadLocalIndex = new ThreadLocal<>(); private final Random random = new Random(); private final static int POSITIVE_MASK = 0x7FFFFFFF;

public int incrementAndGet() { Integer index = this.threadLocalIndex.get(); if (null == index) { index = random.nextInt(); } this.threadLocalIndex.set(++index); return Math.abs(index & POSITIVE_MASK); }

这个threadLocal变量threadLocalIndex用于许多地方，用于均匀分布消息。

IMO，我认为线程局部变量可能不是一个好主意，全局变量（或类变量）应该更适合确保消息在全局均匀分布。

threadlocal变量将没有问题，特别是当分发大量消息时，结果消息将均匀分布。但是，当消息数量较小，消息队列稍大时，可能会看到消息分布不均。

我不太熟悉distribution逻辑，所以如果我错了，请纠正我。

原提问者GitHub用户xiaoyifang