From a1cdb2aa635dc1afcb60fbcf513088f664bfbfc7 Mon Sep 17 00:00:00 2001 From: jianan <1072772483@qq.com> Date: Wed, 27 Jul 2022 17:27:18 +0800 Subject: [PATCH] =?UTF-8?q?doc[module]:=20=E4=BF=AE=E6=94=B9asyncAsk?= =?UTF-8?q?=E7=9A=84argument=E5=8F=82=E6=95=B0=E6=B3=A8=E9=87=8A=EF=BC=8C?= =?UTF-8?q?=E5=AE=83=E4=BB=8E=E6=AD=A4=E5=8F=AA=E6=9C=891=E4=B8=AA?= =?UTF-8?q?=E5=90=AB=E4=B9=89=E4=BA=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- net/src/main/java/com/zfoo/net/router/Router.java | 2 +- net/src/main/java/com/zfoo/net/task/TaskBus.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/net/src/main/java/com/zfoo/net/router/Router.java b/net/src/main/java/com/zfoo/net/router/Router.java index 026196a9..19716201 100644 --- a/net/src/main/java/com/zfoo/net/router/Router.java +++ b/net/src/main/java/com/zfoo/net/router/Router.java @@ -229,7 +229,7 @@ public class Router implements IRouter { /** * 注意: * 1.这个里面其实还是调用send发送的消息 - * 2.这个argument的参数,不仅是在asyncAsk回调时要到哪个线程用, 在provider执行方也用 + * 2.这个argument的参数,只用于provider处哪个线程执行,其实就是hashId,如:工会业务,则传入guildId,回调回来后,一定会在发起者线程。 * * @param session * @param packet 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 26ee579d..af12e816 100644 --- a/net/src/main/java/com/zfoo/net/task/TaskBus.java +++ b/net/src/main/java/com/zfoo/net/task/TaskBus.java @@ -131,6 +131,7 @@ public final class TaskBus { var threadId = Thread.currentThread().getId(); var executor = threadMap.get(threadId); if (executor == null) { + logger.error("threadId:[{}]找不到对应的executor", threadId); return executor(RandomUtils.randomInt()); } return executor;