diff --git a/event/src/main/java/com/zfoo/event/manager/EventBus.java b/event/src/main/java/com/zfoo/event/manager/EventBus.java index 328641e7..a1e2821d 100644 --- a/event/src/main/java/com/zfoo/event/manager/EventBus.java +++ b/event/src/main/java/com/zfoo/event/manager/EventBus.java @@ -118,7 +118,7 @@ public abstract class EventBus { var listAsync = receiverMapAsync.get(clazz); if (CollectionUtils.isNotEmpty(listAsync)) { for (var receiver : listAsync) { - executors[Math.abs(event.threadId() % EXECUTORS_SIZE)].execute(() -> { + execute(event.executorHash(), () -> { try { receiver.invoke(event); } catch (Exception e) { @@ -139,8 +139,8 @@ public abstract class EventBus { /** * Use the event thread specified by the hashcode to execute the task */ - public static void execute(int hashcode, Runnable runnable) { - executors[Math.abs(hashcode % EXECUTORS_SIZE)].execute(SafeRunnable.valueOf(runnable)); + public static void execute(int executorHash, Runnable runnable) { + executors[Math.abs(executorHash % EXECUTORS_SIZE)].execute(SafeRunnable.valueOf(runnable)); } /** diff --git a/event/src/main/java/com/zfoo/event/model/event/IEvent.java b/event/src/main/java/com/zfoo/event/model/event/IEvent.java index e98578aa..9fc252bb 100644 --- a/event/src/main/java/com/zfoo/event/model/event/IEvent.java +++ b/event/src/main/java/com/zfoo/event/model/event/IEvent.java @@ -37,7 +37,7 @@ public interface IEvent { * * @return 线程池的执行的一个参数 */ - default int threadId() { + default int executorHash() { return RandomUtils.randomInt(); }