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

fix ci

Browse Source
This commit is contained in:
Carl Lerche
2023-05-16 17:42:30 -07:00
parent 2a1e36ac44
commit d98aed5789
2 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tokio/src/runtime/scheduler/multi_thread/worker.rs
+8 -8
View File
@@ -721,14 +721,14 @@ impl Core {
if self.is_searching { if self.is_searching {
self.is_searching = false; self.is_searching = false;
if worker.handle.shared.idle.transition_worker_from_searching() { if worker.handle.shared.idle.transition_worker_from_searching()
if worker.handle.work_to_steal() { && worker.handle.work_to_steal()
// Transition *back* to searching {
self.is_searching = true; // Transition *back* to searching
worker.handle.shared.idle.transition_worker_to_searching(); self.is_searching = true;
worker.handle.shared.idle.transition_worker_to_searching();
return false; return false;
}
} }
} }
@@ -869,7 +869,7 @@ impl Handle {
.push_back(task, &self.shared.inject, &mut core.metrics); .push_back(task, &self.shared.inject, &mut core.metrics);
} else { } else {
// Push to the LIFO slot // Push to the LIFO slot
let prev = core.lifo_slot(&self).swap_local(task); let prev = core.lifo_slot(self).swap_local(task);
if let Some(prev) = prev { if let Some(prev) = prev {
core.run_queue core.run_queue
tokio/src/runtime/task/atomic_cell.rs
+2 -2
View File
@@ -54,7 +54,7 @@ impl<S> AtomicCell<S> {
if self if self
.task .task
.compare_exchange(prev, next, Release, Acquire) .compare_exchange(prev, next, AcqRel, Acquire)
.is_ok() .is_ok()
{ {
// Safety: we already checked !null above // Safety: we already checked !null above
@@ -85,6 +85,6 @@ impl<S> AtomicCell<S> {
return Some(unsafe { Notified::from_raw(NonNull::new_unchecked(task)) }); return Some(unsafe { Notified::from_raw(NonNull::new_unchecked(task)) });
} }
return None; None
} }
} }