Merge pull request #44 from cherish-ltt/v1.2.x

v1.2.0-release

Author: cherish-ltt

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "lynn_tcp"
-version = "1.2.0-rc.2"
+version = "1.2.0"
 edition = "2024"
 rust-version = "1.90"
 authors = ["lynn_tcp Contributors"]

Cargo.toml

@@ -208,13 +208,13 @@ Disconnecting reconnection mechanism
 
 ### Test results
 
-platform: Debian12.9 (4H4G)
+platform: Debian12.12 (4H4G) - 2025.10.21
 
 model-1: one request by one response
 
 model-2: concurrent `send request` and `recv response`
 
-total-time: 20s
+total-time: 15s
 
 **version: lynn_tcp-v1.1.x**
 
@@ -230,11 +230,11 @@ total-time: 20s
 
 | client concurrency | model-1(Responses/Seconds) | model-2(Responses/Seconds) |
 | :----------------- | -------------------------- | -------------------------- |
-| 256                | 45,816                     | 437,347                    |
-| 512                | 182,296                    | 259,459                    |
-| 1024               | 163,307                    | 140,934                    |
-| 2048               | 131,346                    | 59,427                     |
-| 4096               | 124,645                    | 37,034                     |
+| 256                | 64,630                     | 492,889                    |
+| 512                | 182,296                    | 300,550                    |
+| 1024               | 163,307                    | 158,056                    |
+| 2048               | 131,346                    | 71,263                     |
+| 4096               | 124,645                    | 52,163                     |
 
 ### License
 

README.md

@@ -192,7 +192,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
 ### 测试结果
 
-平台: Debian12.9 (4H4G)
+平台: Debian12.12 (4H4G)
 
 model-1: one request by one response
 
@@ -214,11 +214,11 @@ model-2: concurrent `send request` and `recv response`
 
 | client concurrency | model-1(Responses/Seconds) | model-2(Responses/Seconds) |
 | :----------------- | -------------------------- | -------------------------- |
-| 256                | 45,816                     | 437,347                    |
-| 512                | 182,296                    | 259,459                    |
-| 1024               | 163,307                    | 140,934                    |
-| 2048               | 131,346                    | 59,427                     |
-| 4096               | 124,645                    | 37,034                     |
+| 256                | 64,630                     | 492,889                    |
+| 512                | 182,296                    | 300,550                    |
+| 1024               | 163,307                    | 158,056                    |
+| 2048               | 131,346                    | 71,263                     |
+| 4096               | 124,645                    | 52,163                     |
 
 ### 开源协议
 

README_ZH.md

@@ -67,16 +67,13 @@ impl EventManager {
             Vec::with_capacity(*server_max_reactor_taskpool_size);
         let mut stealers: Vec<Stealer<ReactorEvent>> =
             Vec::with_capacity(*server_max_reactor_taskpool_size);
-
         for _ in 0..*server_max_reactor_taskpool_size {
             let worker = Worker::new_fifo();
             stealers.push(worker.stealer());
             local_queues.push(worker);
         }
-
         let global_queue = self.global_queue.clone();
         let stealers_arc = Arc::new(stealers);
-
         for (index, local_queue) in local_queues.into_iter().enumerate() {
             let global_queue_clone = global_queue.clone();
             let stealers_arc_clone = stealers_arc.clone();
@@ -85,14 +82,13 @@ impl EventManager {
             let reactor_event_sender = reactor_event_sender.clone();
             let tx = tx.clone();
             let lynn_router = lynn_router.clone();
+            let mut idle_count: u16 = 0;
 
             tokio::spawn(async move {
                 let local_queue = local_queue;
                 let global_queue = global_queue_clone;
                 let stealers_arc = stealers_arc_clone;
                 let clients = clients_clone;
-                let mut idle_count = 0;
-
                 loop {
                     if let Some(event) =
                         get_event(&local_queue, &global_queue, &stealers_arc, index)
@@ -132,11 +128,14 @@ impl EventManager {
                             }
                         }
                     } else {
-                        idle_count += 1;
-                        if idle_count < 64 {
+                        idle_count.saturating_add(1);
+                        if idle_count < 32 {
                             // Temporarily relinquish control
                             yield_now().await;
-                        } else if idle_count < 256 {
+                        } else if idle_count < 1024_0 {
+                            // A slightly longer wait
+                            tokio::time::sleep(Duration::from_millis(1)).await;
+                        } else if idle_count < 32767 {
                             // A slightly longer wait
                             tokio::time::sleep(Duration::from_millis(5)).await;
                         } else {
@@ -149,7 +148,6 @@ impl EventManager {
         }
     }
 
-    #[inline(always)]
     pub(crate) fn get_global_queue(&self) -> ReactorEventSender {
         self.global_queue.clone()
     }
@@ -168,27 +166,29 @@ fn get_event(
     }
 
     // 2. global
-    match global_queue.steal_batch_and_pop(local_queue) {
-        Steal::Success(event) => return Some(event),
-        Steal::Empty => {}
-        Steal::Retry => {}
+    if let Steal::Success(event) = global_queue.steal_batch_and_pop(local_queue) {
+        return Some(event);
     }
 
     // 3. stealers
     let stealers_len = stealers_arc.len();
+
     if stealers_len > 1 {
         let start_index = (worker_index + 1) % stealers_len;
 
         for i in 0..stealers_len {
             let steal_index = (start_index + i) % stealers_len;
+
             match stealers_arc[steal_index].steal() {
                 Steal::Success(event) => return Some(event),
+
                 Steal::Empty | Steal::Retry => continue,
             }
         }
     } else if stealers_len == 1 {
         match stealers_arc[0].steal() {
             Steal::Success(event) => return Some(event),
+
             Steal::Empty | Steal::Retry => {}
         }
     }

src/app/tcp_reactor/event.rs

@@ -10,6 +10,10 @@
 
 ### v1.2.x - rc
 
+#### v1.2.0-release
+
+Integrate v1.2.0-rc.1,rc.2
+
 #### v1.2.0-rc.2
 
 Optimize network handling performance(by ai-agent GLM4.6)
@@ -202,4 +206,4 @@ We are testing and using `AI agent-GLM4.6` for the first time to optimize and de
 
 - Automatically clean sockets
 
-- Routing service for synchronous tasks
+- Routing service for synchronous tasks