From 029b43d54a75b13f23965ee55215536a7df70ac6 Mon Sep 17 00:00:00 2001
From: sun <jaysunxiao@gmail.com>
Date: Wed, 20 Sep 2023 18:11:49 +0800
Subject: [PATCH] test[thread local]: virtual thead local test

---
 .../com/zfoo/net/core/tcpSync/client/TcpClientTest.java   | 1 -
 .../zfoo/net/core/tcpSync/server/TcpSyncController.java   | 8 +++++---
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/net/src/test/java/com/zfoo/net/core/tcpSync/client/TcpClientTest.java b/net/src/test/java/com/zfoo/net/core/tcpSync/client/TcpClientTest.java
index 28143d8d..c49fff0d 100644
--- a/net/src/test/java/com/zfoo/net/core/tcpSync/client/TcpClientTest.java
+++ b/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);
diff --git a/net/src/test/java/com/zfoo/net/core/tcpSync/server/TcpSyncController.java b/net/src/test/java/com/zfoo/net/core/tcpSync/server/TcpSyncController.java
index 37069982..fa17a672 100644
--- a/net/src/test/java/com/zfoo/net/core/tcpSync/server/TcpSyncController.java
+++ b/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);
     }
 
 }