ref[event]: rename

zfoo-project · Apr 10, 2024 · 76c20ff · 76c20ff
1 parent 966fe14
commit 76c20ff
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 7 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
@@ -114,7 +114,7 @@ public static void post(IEvent event) {
         for (var receiver : receivers) {
             switch (receiver.bus()) {
                 case CurrentThread -> doReceiver(receiver, event);
-                case AsyncThread -> execute(event.executorHash(), () -> doReceiver(receiver, event));
+                case AsyncThread -> asyncExecute(event.executorHash(), () -> doReceiver(receiver, event));
 //                case VirtualThread -> Thread.ofVirtual().name("virtual-on" + clazz.getSimpleName()).start(() -> doReceiver(receiver, event));
             }
         }
@@ -132,13 +132,13 @@ private static void doReceiver(IEventReceiver receiver, IEvent event) {
     }
 
     public static void asyncExecute(Runnable runnable) {
-        execute(RandomUtils.randomInt(), runnable);
+        asyncExecute(RandomUtils.randomInt(), runnable);
     }
 
     /**
      * Use the event thread specified by the hashcode to execute the task
      */
-    public static void execute(int executorHash, Runnable runnable) {
+    public static void asyncExecute(int executorHash, Runnable runnable) {
         executors[Math.abs(executorHash % EXECUTORS_SIZE)].execute(ThreadUtils.safeRunnable(runnable));
     }
 

diff --git a/net/src/test/java/com/zfoo/net/router/SignalBridgeTest.java b/net/src/test/java/com/zfoo/net/router/SignalBridgeTest.java
@@ -45,7 +45,7 @@ public void arrayTest() throws InterruptedException {
 
         var countDownLatch = new CountDownLatch(executorSize);
         for (var i = 0; i < executorSize; i++) {
-            EventBus.execute(i, new Runnable() {
+            EventBus.asyncExecute(i, new Runnable() {
                 @Override
                 public void run() {
                     addAndRemoveArray();

diff --git a/orm/src/main/java/com/zfoo/orm/cache/EntityCache.java b/orm/src/main/java/com/zfoo/orm/cache/EntityCache.java
@@ -69,7 +69,7 @@ public void accept(Pair<PK, PNode<E>> pair, LazyCache.RemovalCause removalCause)
                 var entity = pnode.getEntity();
                 @SuppressWarnings("unchecked")
                 var entityClass = (Class<E>) entityDef.getClazz();
-                EventBus.execute(entityClass.hashCode(), new Runnable() {
+                EventBus.asyncExecute(entityClass.hashCode(), new Runnable() {
                     @Override
                     public void run() {
                         var collection = OrmContext.getOrmManager().getCollection(entityClass);

diff --git a/orm/src/main/java/com/zfoo/orm/cache/persister/CronOrmPersister.java b/orm/src/main/java/com/zfoo/orm/cache/persister/CronOrmPersister.java
@@ -75,7 +75,7 @@ private void schedulePersist() {
         if (!OrmContext.isStop()) {
             SchedulerBus.schedule(() -> {
                 if (!OrmContext.isStop()) {
-                    EventBus.execute(entityDef.getClazz().hashCode(), () -> {
+                    EventBus.asyncExecute(entityDef.getClazz().hashCode(), () -> {
                         entityCaches.persistAll();
                         schedulePersist();
                     });

diff --git a/orm/src/main/java/com/zfoo/orm/cache/persister/TimeOrmPersister.java b/orm/src/main/java/com/zfoo/orm/cache/persister/TimeOrmPersister.java
@@ -44,7 +44,7 @@ public TimeOrmPersister(EntityDef entityDef, EntityCache<?, ?> entityCaches) {
     public void start() {
         SchedulerBus.scheduleAtFixedRate(() -> {
             if (!OrmContext.isStop()) {
-                EventBus.execute(entityDef.getClazz().hashCode(), () -> entityCaches.persistAll());
+                EventBus.asyncExecute(entityDef.getClazz().hashCode(), () -> entityCaches.persistAll());
             }
         }, rate, TimeUnit.MILLISECONDS);
     }