mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-05-19 19:27:16 +00:00
doc[module]: 修改asyncAsk的argument参数注释,它从此只有1个含义了
This commit is contained in:
@@ -229,7 +229,7 @@ public class Router implements IRouter {
|
||||
/**
|
||||
* 注意:
|
||||
* 1.这个里面其实还是调用send发送的消息
|
||||
* 2.这个argument的参数,不仅是在asyncAsk回调时要到哪个线程用, 在provider执行方也用
|
||||
* 2.这个argument的参数,只用于provider处哪个线程执行,其实就是hashId,如:工会业务,则传入guildId,回调回来后,一定会在发起者线程。
|
||||
*
|
||||
* @param session
|
||||
* @param packet
|
||||
|
||||
@@ -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;
|
||||
|
||||
Reference in New Issue
Block a user