mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-10-13 22:16:32 +00:00
build[release]: first release
This commit is contained in:
1 parent
b3cb80cafe
commit
7a934a70f8
4 files changed
+2
-4
No files matched your search
@@ -21,7 +21,7 @@ jobs:
|
||||
|
||||
steps:
|
||||
- uses: actions/checkout@v3
|
||||
- name: Set up JDK 21
|
||||
- name: Set up JDK 17
|
||||
uses: actions/setup-java@v3
|
||||
with:
|
||||
java-version: '17'
|
||||
|
||||
@@ -103,7 +103,6 @@ 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,7 +204,6 @@ 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,6 @@ 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