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;