From 3f89e0e7abbc09d91f03110bf2429b877013eec9 Mon Sep 17 00:00:00 2001
From: godotg <jaysunxiao@gmail.com>
Date: Tue, 7 May 2024 15:56:25 +0800
Subject: [PATCH] feat[task]: run packet receiver task in EventBus

---
 net/src/main/java/com/zfoo/net/anno/Task.java     | 2 ++
 net/src/main/java/com/zfoo/net/router/Router.java | 1 +
 2 files changed, 3 insertions(+)

diff --git a/net/src/main/java/com/zfoo/net/anno/Task.java b/net/src/main/java/com/zfoo/net/anno/Task.java
index d8781b61..36531fb4 100644
--- 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
index 1b4699fb..283bdc15 100644
--- 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 class Router implements IRouter {
 
         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));
         }