itsscb/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2025-10-01 12:20:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

wip

Browse Source
This commit is contained in:
Carl Lerche 2023-06-13 13:14:10 -07:00
parent 464e59caab
commit 152d4fc899
No known key found for this signature in database
GPG Key ID: FC5ADF3A4B2E5977
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tokio/src/runtime/scheduler/multi_thread/worker.rs
View File

@ -515,8 +515,7 @@ fn run(
// the worker core is lost due to `block_in_place()` being called from // the worker core is lost due to `block_in_place()` being called from
// within the task. // within the task.
if !cx.defer.borrow().is_empty() { if !cx.defer.borrow().is_empty() {
// cx.defer.wake(); worker.schedule_deferred_without_core(&cx, &mut cx.shared().synced.lock());
todo!()
} }
}); });
}); });
@ -1213,6 +1212,7 @@ impl Worker {
fn can_transition_to_parked(&self, cx: &Context, core: &mut Core) -> bool { fn can_transition_to_parked(&self, cx: &Context, core: &mut Core) -> bool {
cx.shared().remotes[core.index].lifo_slot.is_none() cx.shared().remotes[core.index].lifo_slot.is_none()
&& core.run_queue.is_empty() && core.run_queue.is_empty()
&& !core.is_shutdown
&& !core.is_traced && !core.is_traced
} }