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

let's see what happens if i just...

Browse Source
This commit is contained in:
Eliza Weisman
2026-04-16 12:24:51 -07:00
parent 812de3e134
commit dffcd031d0
1 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tokio/src/runtime/blocking/sharded_queue.rs
+10 -7
View File
@@ -22,13 +22,16 @@ use std::time::Duration;
use super::pool::Task;
/// Number of shards. Must be a power of 2.
/// Under loom, use a single shard to keep the state space tractable —
/// the concurrency properties we need to verify (condvar signaling,
/// shutdown ordering) are independent of shard count.
#[cfg(not(loom))]
const NUM_SHARDS: usize = 16;
#[cfg(loom)]
// TODO(eliza): make this configurable and swap between 1/16 shards based on
// whether the runtime builder enables the sharded queue...
//
// /// Number of shards. Must be a power of 2.
// /// Under loom, use a single shard to keep the state space tractable —
// /// the concurrency properties we need to verify (condvar signaling,
// /// shutdown ordering) are independent of shard count.
// #[cfg(not(loom))]
// const NUM_SHARDS: usize = 16;
// #[cfg(loom)]
const NUM_SHARDS: usize = 1;
/// A single shard containing a queue protected by its own mutex.