From fb219cd1caf5d598f4d0bf6b7075258e5a32b321 Mon Sep 17 00:00:00 2001 From: godotg Date: Thu, 28 Jul 2022 16:32:28 +0800 Subject: [PATCH] =?UTF-8?q?ref[net]:=20=E4=BC=98=E5=8C=96=E6=96=B9?= =?UTF-8?q?=E6=B3=95=E5=90=8D=E7=A7=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 | 4 +++- 1 file changed, 3 insertions(+), 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 51246018..88a7757f 100644 --- a/net/src/main/java/com/zfoo/net/task/TaskBus.java +++ b/net/src/main/java/com/zfoo/net/task/TaskBus.java @@ -32,6 +32,8 @@ import java.util.concurrent.*; import java.util.concurrent.atomic.AtomicInteger; /** + * Task线程池一半是用来接收客户都安的请求做一些cpu密集型任务,尽量避免做一些阻塞操作,IO密集型任务可以放在Event线程池去做 + * * @author godotg * @version 3.0 */ @@ -125,7 +127,7 @@ public final class TaskBus { return Math.abs(executorConsistentHash % EXECUTOR_SIZE); } - public static void executor(int executorConsistentHash, SafeRunnable runnable) { + public static void execute(int executorConsistentHash, SafeRunnable runnable) { executors[executorIndex(executorConsistentHash)].execute(runnable); }