feat[task]: run packet receiver task in EventBus

zfoo-project · May 7, 2024 · 3f89e0e · 3f89e0e
1 parent 2e2083f
commit 3f89e0e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/net/src/main/java/com/zfoo/net/anno/Task.java b/net/src/main/java/com/zfoo/net/anno/Task.java
@@ -20,6 +20,8 @@ public enum Task {
 
     TaskBus,
 
+    EventBus,
+
     NettyIO,
 
     VirtualThread;

diff --git a/net/src/main/java/com/zfoo/net/router/Router.java b/net/src/main/java/com/zfoo/net/router/Router.java
@@ -186,6 +186,7 @@ public void dispatchByTaskExecutorHash(int taskExecutorHash, PacketReceiverTask
 
         switch (receiver.task()) {
             case TaskBus -> TaskBus.execute(taskExecutorHash, packetReceiverTask);
+            case EventBus -> EventBus.asyncExecute(taskExecutorHash, packetReceiverTask);
             case NettyIO -> atReceiver(packetReceiverTask);
 //            case VirtualThread -> Thread.ofVirtual().name("virtual-at" + clazz.getSimpleName()).start(() -> atReceiver(packetReceiverTask));
         }