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

try loom again

Browse Source
This commit is contained in:
Carl Lerche
2023-05-17 10:13:13 -07:00
parent d98aed5789
commit f4f3f509ac
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tokio/src/runtime/scheduler/multi_thread/worker.rs
+4
View File
@@ -642,8 +642,12 @@ impl Core {
/// a new worker will actually try to steal. The idea is to make sure not all /// a new worker will actually try to steal. The idea is to make sure not all
/// workers will be trying to steal at the same time. /// workers will be trying to steal at the same time.
fn steal_work(&mut self, worker: &Worker) -> Option<Notified> { fn steal_work(&mut self, worker: &Worker) -> Option<Notified> {
#[cfg(not(loom))]
const ATTEMPTS: usize = 4; const ATTEMPTS: usize = 4;
#[cfg(loom)]
const ATTEMPTS: usize = 1;
// Number of remotes // Number of remotes
let num = worker.handle.shared.remotes.len(); let num = worker.handle.shared.remotes.len();