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

runtime: add cfg for loom specific code (#6694)

Browse Source
This commit is contained in:
Motoyuki Kimura 2024-07-22 00:26:36 +09:00 committed by GitHub
parent 1be8a8e691
commit 3ad5b6df1a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tokio/src/runtime/blocking/pool.rs
View File

@ -264,8 +264,12 @@ impl BlockingPool {
// Loom requires that execution be deterministic, so sort by thread ID before joining. // Loom requires that execution be deterministic, so sort by thread ID before joining.
// (HashMaps use a randomly-seeded hash function, so the order is nondeterministic) // (HashMaps use a randomly-seeded hash function, so the order is nondeterministic)
let mut workers: Vec<(usize, thread::JoinHandle<()>)> = workers.into_iter().collect(); #[cfg(loom)]
let workers: Vec<(usize, thread::JoinHandle<()>)> = {
let mut workers: Vec<_> = workers.into_iter().collect();
workers.sort_by_key(|(id, _)| *id); workers.sort_by_key(|(id, _)| *id);
workers
};
for (_id, handle) in workers { for (_id, handle) in workers {
let _ = handle.join(); let _ = handle.join();