mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-08-09 02:25:20 +00:00
chore[virtual]: mark java 21 code
This commit is contained in:
@@ -103,6 +103,7 @@ public abstract class EventBus {
|
||||
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));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -204,6 +204,7 @@ public class Router implements IRouter {
|
||||
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));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -24,6 +24,7 @@ public class FastThreadLocalAdapter<T> {
|
||||
}
|
||||
|
||||
public T get() {
|
||||
// return Thread.currentThread().isVirtual() ? supplier.get() : fastThreadLocal.get();
|
||||
return fastThreadLocal.get();
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user