mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-05-26 07:59:56 +00:00
feat[task]: run packet receiver task in EventBus
This commit is contained in:
@@ -20,6 +20,8 @@ public enum Task {
|
||||
|
||||
TaskBus,
|
||||
|
||||
EventBus,
|
||||
|
||||
NettyIO,
|
||||
|
||||
VirtualThread;
|
||||
|
||||
@@ -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));
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user