diff --git a/boot/pom.xml b/boot/pom.xml
index 21886bed..8e19caa0 100644
--- a/boot/pom.xml
+++ b/boot/pom.xml
@@ -48,7 +48,7 @@
${file.encoding}
${file.encoding}
- 17
+ 21
UTF-8
diff --git a/event/pom.xml b/event/pom.xml
index 2851468c..158e6c68 100644
--- a/event/pom.xml
+++ b/event/pom.xml
@@ -48,7 +48,7 @@
${file.encoding}
${file.encoding}
- 17
+ 21
UTF-8
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 43b9aa75..db46e4f7 100644
--- a/event/src/main/java/com/zfoo/event/manager/EventBus.java
+++ b/event/src/main/java/com/zfoo/event/manager/EventBus.java
@@ -108,7 +108,7 @@ public abstract class EventBus {
execute(event.executorHash(), () -> doReceiver(receiver, event));
break;
case VirtualThread:
- logger.error("waiting for java 21 virtual thread");
+ Thread.ofVirtual().name("virtual-" + clazz.getSimpleName()).start(ThreadUtils.safeRunnable(() -> doReceiver(receiver, event)));
break;
}
}
diff --git a/event/src/test/java/com/zfoo/event/MyController2.java b/event/src/test/java/com/zfoo/event/MyController2.java
index 73224dc0..88af6276 100644
--- a/event/src/test/java/com/zfoo/event/MyController2.java
+++ b/event/src/test/java/com/zfoo/event/MyController2.java
@@ -29,7 +29,6 @@ public class MyController2 {
/**
* 同一个事件可以被重复注册和接受
- *
* 异步事件会被不会立刻执行,注意日志打印的线程号
*/
@EventReceiver(Bus.AsyncThread)
diff --git a/event/src/test/java/com/zfoo/event/MyController3.java b/event/src/test/java/com/zfoo/event/MyController3.java
new file mode 100644
index 00000000..4390075d
--- /dev/null
+++ b/event/src/test/java/com/zfoo/event/MyController3.java
@@ -0,0 +1,35 @@
+/*
+ * Copyright (C) 2020 The zfoo Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed
+ * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and limitations under the License.
+ */
+
+package com.zfoo.event;
+
+import com.zfoo.event.anno.Bus;
+import com.zfoo.event.anno.EventReceiver;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author godotg
+ */
+@Component
+public class MyController3 {
+
+ private static final Logger logger = LoggerFactory.getLogger(MyController3.class);
+
+ @EventReceiver(Bus.VirtualThread)
+ public void onMyNoticeEvent(MyNoticeEvent event) {
+ logger.info("方法3虚拟线程执行事件:" + event.getMessage());
+ }
+
+}
diff --git a/hotswap/pom.xml b/hotswap/pom.xml
index 500cbdec..6fc6845e 100644
--- a/hotswap/pom.xml
+++ b/hotswap/pom.xml
@@ -48,7 +48,7 @@
${file.encoding}
${file.encoding}
- 17
+ 21
UTF-8
diff --git a/monitor/pom.xml b/monitor/pom.xml
index dcc60111..f66d63a0 100644
--- a/monitor/pom.xml
+++ b/monitor/pom.xml
@@ -48,7 +48,7 @@
${file.encoding}
${file.encoding}
- 17
+ 21
UTF-8
diff --git a/net/pom.xml b/net/pom.xml
index ae8fc189..475e6998 100644
--- a/net/pom.xml
+++ b/net/pom.xml
@@ -48,7 +48,7 @@
${file.encoding}
${file.encoding}
- 17
+ 21
UTF-8
diff --git a/orm/pom.xml b/orm/pom.xml
index d6ccdf05..c6c144ab 100644
--- a/orm/pom.xml
+++ b/orm/pom.xml
@@ -48,7 +48,7 @@
${file.encoding}
${file.encoding}
- 17
+ 21
UTF-8
diff --git a/pom.xml b/pom.xml
index edd9b8bc..28049db8 100644
--- a/pom.xml
+++ b/pom.xml
@@ -164,7 +164,7 @@
${file.encoding}
${file.encoding}
- 17
+ 21
UTF-8
diff --git a/protocol/pom.xml b/protocol/pom.xml
index 347701e8..5be8cc09 100644
--- a/protocol/pom.xml
+++ b/protocol/pom.xml
@@ -48,7 +48,7 @@
${file.encoding}
${file.encoding}
- 17
+ 21
UTF-8
diff --git a/scheduler/pom.xml b/scheduler/pom.xml
index 1958ca24..acfe86c0 100644
--- a/scheduler/pom.xml
+++ b/scheduler/pom.xml
@@ -48,7 +48,7 @@
${file.encoding}
${file.encoding}
- 17
+ 21
UTF-8
diff --git a/storage/pom.xml b/storage/pom.xml
index b132c641..ba6de0df 100644
--- a/storage/pom.xml
+++ b/storage/pom.xml
@@ -48,7 +48,7 @@
${file.encoding}
${file.encoding}
- 17
+ 21
UTF-8