From c23db9090e6d43f21727c0095b0311944eef02d9 Mon Sep 17 00:00:00 2001 From: "zhou.yihao" <360175245@qq.com> Date: Wed, 5 Jun 2024 14:55:10 +0800 Subject: [PATCH] =?UTF-8?q?fix[net]:=20TaskBus=E8=AE=A1=E7=AE=97hash?= =?UTF-8?q?=E7=9A=84=E6=97=B6=E5=80=99=EF=BC=8C=E5=9C=A8taskExecutorHash?= =?UTF-8?q?=E8=BE=BE=E5=88=B0int=E6=9C=80=E5=A4=A7=E5=80=BC=E7=9A=84?= =?UTF-8?q?=E6=97=B6=E5=80=99=EF=BC=8C=E8=AE=A1=E7=AE=97=E5=87=BA=E6=9D=A5?= =?UTF-8?q?=E6=98=AF=E8=B4=9F=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- net/src/main/java/com/zfoo/net/task/TaskBus.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/net/src/main/java/com/zfoo/net/task/TaskBus.java b/net/src/main/java/com/zfoo/net/task/TaskBus.java index 417b2d37..0928e5c9 100644 --- a/net/src/main/java/com/zfoo/net/task/TaskBus.java +++ b/net/src/main/java/com/zfoo/net/task/TaskBus.java @@ -95,7 +95,7 @@ public final class TaskBus { private static int calTaskExecutorIndex(int taskExecutorHash) { // Other hash algorithms can be customized to make the distribution more uniform - return Math.abs(taskExecutorHash) % EXECUTOR_SIZE; + return Math.abs(taskExecutorHash % EXECUTOR_SIZE); } public static int calTaskExecutorHash(Object argument) {