Remove yield_now

akiradeveloper · Nov 2, 2024 · 41cb7c9 · 41cb7c9
1 parent c7d23db
commit 41cb7c9
Show file tree

Hide file tree

Showing 4 changed files with 1 addition and 6 deletions.
diff --git a/sorock/src/process/thread/advance_kern.rs b/sorock/src/process/thread/advance_kern.rs
@@ -20,7 +20,6 @@ impl Thread {
                 self.consumer.consume_events(Duration::from_secs(1)).await;
                 while self.advance_once().await.is_ok() {
                     self.producer.push_event(KernEvent);
-                    tokio::task::yield_now().await;
                 }
             }
         };

diff --git a/sorock/src/process/thread/advance_user.rs b/sorock/src/process/thread/advance_user.rs
@@ -21,7 +21,6 @@ impl Thread {
                 self.consumer.consume_events(Duration::from_secs(1)).await;
                 while self.advance_once().await.is_ok() {
                     self.producer.push_event(ApplicationEvent);
-                    tokio::task::yield_now().await;
                 }
             }
         };

diff --git a/sorock/src/process/thread/query_execution.rs b/sorock/src/process/thread/query_execution.rs
@@ -19,9 +19,7 @@ impl Thread {
                 self.consumer
                     .consume_events(Duration::from_millis(100))
                     .await;
-                while self.advance_once().await {
-                    tokio::task::yield_now().await;
-                }
+                while self.advance_once().await {}
             }
         };
         let hdl = tokio::spawn(fut).abort_handle();

diff --git a/sorock/src/process/thread/replication.rs b/sorock/src/process/thread/replication.rs
@@ -28,7 +28,6 @@ impl Thread {
                 self.consumer.consume_events(Duration::from_secs(1)).await;
                 while let Ok(true) = self.advance_once().await {
                     self.producer.push_event(ReplicationEvent);
-                    tokio::task::yield_now().await;
                 }
             }
         };