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) {