chore[virtual]: mark java 21 code

zfoo-project · Sep 21, 2023 · ce9cc21 · ce9cc21
1 parent eeefb69
commit ce9cc21
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 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
@@ -103,6 +103,7 @@ public static void post(IEvent event) {
             switch (receiver.bus()) {
                 case CurrentThread -> doReceiver(receiver, event);
                 case AsyncThread -> execute(event.executorHash(), () -> doReceiver(receiver, event));
+//                case VirtualThread -> Thread.ofVirtual().name("virtual-on" + clazz.getSimpleName()).start(() -> doReceiver(receiver, event));
             }
         }
     }

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

diff --git a/protocol/src/main/java/com/zfoo/protocol/util/FastThreadLocalAdapter.java b/protocol/src/main/java/com/zfoo/protocol/util/FastThreadLocalAdapter.java
@@ -24,6 +24,7 @@ protected T initialValue() {
     }
 
     public T get() {
+//        return Thread.currentThread().isVirtual() ? supplier.get() : fastThreadLocal.get();
         return fastThreadLocal.get();
     }
 }