From 91cfd38052f84a12c8bf68d9c9cef17b9b73ba97 Mon Sep 17 00:00:00 2001 From: jaysunxiao Date: Tue, 17 Aug 2021 12:42:12 +0800 Subject: [PATCH] =?UTF-8?q?perf[task]:=20=E5=8E=BB=E6=8E=89=E6=97=A0?= =?UTF-8?q?=E7=94=A8=E7=9A=84=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- net/src/main/java/com/zfoo/net/task/TaskManager.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/net/src/main/java/com/zfoo/net/task/TaskManager.java b/net/src/main/java/com/zfoo/net/task/TaskManager.java index a4a98171..c2d1aa15 100644 --- a/net/src/main/java/com/zfoo/net/task/TaskManager.java +++ b/net/src/main/java/com/zfoo/net/task/TaskManager.java @@ -18,7 +18,6 @@ import com.zfoo.net.task.model.AbstractTaskDispatch; import com.zfoo.net.task.model.ITaskDispatch; import com.zfoo.net.task.model.ReceiveTask; import com.zfoo.protocol.util.StringUtils; -import com.zfoo.util.math.RandomUtils; import io.netty.util.concurrent.FastThreadLocalThread; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -103,10 +102,6 @@ public final class TaskManager implements ITaskManager { @Override public ExecutorService getExecutorByConsistentHash(int executorConsistentHash) { - if (executorConsistentHash >= 0) { - return executors[Math.abs(executorConsistentHash % EXECUTOR_SIZE)]; - } else { - return executors[RandomUtils.randomInt(TaskManager.EXECUTOR_SIZE)]; - } + return executors[Math.abs(executorConsistentHash % EXECUTOR_SIZE)]; } }