tokio-rs/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2026-08-27 00:00:12 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
Carl Lerche
2023-06-22 17:52:31 +00:00
parent 1a2d2df92d
commit 3339103ff5
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tokio/src/runtime/scheduler/multi_thread/worker.rs
+10 -5
View File
@@ -703,17 +703,22 @@ impl Worker {
// We consumed all work in the queues and will start searching for work.
core.stats.end_processing_scheduled_tasks(&mut self.stats);
if !cx.defer.borrow().is_empty() {
// We are deferring tasks, so poll the resource driver and schedule
// the deferred tasks.
core = try_task_new_batch!(self, self.park_yield(cx, core));
panic!("what happened to the deferred tasks? 🤔");
}
while !self.is_shutdown {
// Search for more work, this involves trying to poll the resource
// driver, steal from other workers, and check the global queue
// again.
core = try_task_new_batch!(self, self.search_for_work(cx, core));
if !cx.defer.borrow().is_empty() {
core = try_task_new_batch!(self, self.park_yield(cx, core));
} else {
core = try_task_new_batch!(self, self.park(cx, core));
}
debug_assert!(cx.defer.borrow().is_empty());
core = try_task_new_batch!(self, self.park(cx, core));
}
// Shutting down, drop any deferred tasks