mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-06-09 02:15:21 +00:00
perf[event]: use the latest syntax
This commit is contained in:
@@ -101,15 +101,9 @@ public abstract class EventBus {
|
||||
}
|
||||
for (var receiver : receivers) {
|
||||
switch (receiver.bus()) {
|
||||
case CurrentThread:
|
||||
doReceiver(receiver, event);
|
||||
break;
|
||||
case AsyncThread:
|
||||
execute(event.executorHash(), () -> doReceiver(receiver, event));
|
||||
break;
|
||||
case VirtualThread:
|
||||
Thread.ofVirtual().name("virtual-" + clazz.getSimpleName()).start(ThreadUtils.safeRunnable(() -> doReceiver(receiver, event)));
|
||||
break;
|
||||
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));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user