Fix blockin 1 cpu

frkn-dev · Jan 17, 2025 · d60db1e · d60db1e
1 parent fde61bd
commit d60db1e
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 5 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "pony"
-version = "0.0.11-dev"
+version = "0.0.12-dev"
 edition = "2021"
 build = "build.rs" 
 

diff --git a/src/bin/agent.rs b/src/bin/agent.rs
@@ -30,7 +30,7 @@ use pony::{
 
 #[derive(Parser)]
 #[command(
-    version = "0.0.11-dev",
+    version = "0.0.12-dev",
     about = "Pony Agent - control tool for Xray/Wireguard"
 )]
 struct Cli {
@@ -292,6 +292,6 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     }
 
     // Run all tasks
-    let _ = futures::future::try_join_all(tasks).await;
+    let _ = futures::future::join_all(tasks).await;
     Ok(())
 }
diff --git a/src/bin/api.rs b/src/bin/api.rs
@@ -20,7 +20,7 @@ use pony::{
 
 #[derive(Parser)]
 #[command(
-    version = "0.0.11-dev",
+    version = "0.0.12-dev",
     about = "Pony Api - control tool for Xray/Wireguard"
 )]
 struct Cli {

diff --git a/src/zmq/subscriber.rs b/src/zmq/subscriber.rs
@@ -50,6 +50,7 @@ pub async fn subscriber(
     );
 
     loop {
+        tokio::task::yield_now().await;
         match subscriber.recv_string(0) {
             Ok(Ok(data)) => {
                 let data = data.to_string();