From 5702650159384d2eecaccd271ef80bf3531d363e Mon Sep 17 00:00:00 2001 From: godotg Date: Sat, 11 Mar 2023 14:12:13 +0800 Subject: [PATCH 1/3] feat[event]: support virtual thread api --- .../java/com/zfoo/event/model/vo/EventReceiverDefinition.java | 4 ++-- .../java/com/zfoo/event/schema/EventRegisterProcessor.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/event/src/main/java/com/zfoo/event/model/vo/EventReceiverDefinition.java b/event/src/main/java/com/zfoo/event/model/vo/EventReceiverDefinition.java index 36e46644..0960c3e1 100644 --- a/event/src/main/java/com/zfoo/event/model/vo/EventReceiverDefinition.java +++ b/event/src/main/java/com/zfoo/event/model/vo/EventReceiverDefinition.java @@ -39,12 +39,12 @@ public class EventReceiverDefinition implements IEventReceiver { // 事件接收方式 private Bus bus; - public EventReceiverDefinition(Object bean, Method method, Class eventClazz, Bus bus) { + public EventReceiverDefinition(Object bean, Method method, Bus bus, Class eventClazz) { this.bean = bean; this.method = method; + this.bus = bus; this.eventClazz = eventClazz; ReflectionUtils.makeAccessible(this.method); - this.bus = bus; } @Override diff --git a/event/src/main/java/com/zfoo/event/schema/EventRegisterProcessor.java b/event/src/main/java/com/zfoo/event/schema/EventRegisterProcessor.java index 6e450dfa..d8ebf9b9 100644 --- a/event/src/main/java/com/zfoo/event/schema/EventRegisterProcessor.java +++ b/event/src/main/java/com/zfoo/event/schema/EventRegisterProcessor.java @@ -80,7 +80,7 @@ public class EventRegisterProcessor implements BeanPostProcessor { } var bus = method.getDeclaredAnnotation(EventReceiver.class).value(); - var receiverDefinition = new EventReceiverDefinition(bean, method, eventClazz, bus); + var receiverDefinition = new EventReceiverDefinition(bean, method, bus, eventClazz); var enhanceReceiverDefinition = EnhanceUtils.createEventReceiver(receiverDefinition); // key:class类型 value:观察者 注册Event的receiverMap中 From e95074463ffd113af8626ab9d084efda0d69c52f Mon Sep 17 00:00:00 2001 From: godotg Date: Sat, 11 Mar 2023 14:57:20 +0800 Subject: [PATCH 2/3] feat[event]: support virtual thread api --- event/src/main/java/com/zfoo/event/manager/EventBus.java | 1 + 1 file changed, 1 insertion(+) diff --git a/event/src/main/java/com/zfoo/event/manager/EventBus.java b/event/src/main/java/com/zfoo/event/manager/EventBus.java index b9dce498..b9b09c79 100644 --- a/event/src/main/java/com/zfoo/event/manager/EventBus.java +++ b/event/src/main/java/com/zfoo/event/manager/EventBus.java @@ -110,6 +110,7 @@ public abstract class EventBus { execute(event.executorHash(), () -> doReceiver(receiver, event)); break; case VirtualThread: + logger.error("waiting for java 21 virtual thread"); break; } } From 46cb95238222187a6ae13a5377881e219b80ac12 Mon Sep 17 00:00:00 2001 From: godotg Date: Sat, 11 Mar 2023 20:00:54 +0800 Subject: [PATCH 3/3] feat[event]: support virtual thread api --- .../java/com/zfoo/net/router/attachment/SignalAttachment.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/net/src/main/java/com/zfoo/net/router/attachment/SignalAttachment.java b/net/src/main/java/com/zfoo/net/router/attachment/SignalAttachment.java index 4d90504a..7de58db3 100644 --- a/net/src/main/java/com/zfoo/net/router/attachment/SignalAttachment.java +++ b/net/src/main/java/com/zfoo/net/router/attachment/SignalAttachment.java @@ -48,7 +48,7 @@ public class SignalAttachment implements IAttachment { /** * The time the client sent it */ - private transient long timestamp = TimeUtils.now(); + private long timestamp = TimeUtils.now(); /** * EN:The method of callback when the client receives a reply from the server