test[thread local]: virtual thead local test

net/src/test/java/com/zfoo/net/core/tcpSync/client/TcpClientTest.java

@@ -46,7 +46,6 @@ public class TcpClientTest {
             ask.setMessage("Hello, this is sync client!");
             var answer = NetContext.getRouter().syncAsk(session, ask, SyncMessAnswer.class, null).packet();
             logger.info("同步请求收到结果[{}]", JsonUtils.object2String(answer));
-            ThreadUtils.sleep(1000);
         }
 
         ThreadUtils.sleep(Long.MAX_VALUE);

net/src/test/java/com/zfoo/net/core/tcpSync/server/TcpSyncController.java

@@ -13,9 +13,11 @@
 package com.zfoo.net.core.tcpSync.server;
 
 import com.zfoo.net.NetContext;
+import com.zfoo.net.anno.Task;
 import com.zfoo.net.packet.tcp.SyncMessAnswer;
 import com.zfoo.net.packet.tcp.SyncMessAsk;
 import com.zfoo.net.anno.PacketReceiver;
+import com.zfoo.net.router.attachment.SignalAttachment;
 import com.zfoo.net.session.Session;
 import com.zfoo.protocol.util.JsonUtils;
 import org.slf4j.Logger;
@@ -30,14 +32,14 @@ public class TcpSyncController {
 
     private static final Logger logger = LoggerFactory.getLogger(TcpSyncController.class);
 
-    @PacketReceiver
-    public void atSyncMessAsk(Session session, SyncMessAsk ask) {
+    @PacketReceiver(Task.VirtualThread)
+    public void atSyncMessAsk(Session session, SyncMessAsk ask, SignalAttachment attachment) {
         logger.info("receive [packet:{}] from client", JsonUtils.object2String(ask));
 
         var answer = new SyncMessAnswer();
         answer.setMessage("Hello, this is the tcp server!");
 
-        NetContext.getRouter().send(session, answer);
+        NetContext.getRouter().send(session, answer, attachment);
     }
 
 }