From da9cb5f60880082dd2a14924e43de9fd3cc3d5e0 Mon Sep 17 00:00:00 2001
From: godotg <jaysunxiao@gmail.com>
Date: Wed, 8 Mar 2023 12:00:04 +0800
Subject: [PATCH] ref[event]: rename IEvent threadId method name to
 executorHash

---
 event/src/main/java/com/zfoo/event/manager/EventBus.java   | 6 +++---
 event/src/main/java/com/zfoo/event/model/event/IEvent.java | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

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();
     }