We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 55664f1 commit 81837e7Copy full SHA for 81837e7
src/task/blocking.rs
@@ -100,12 +100,12 @@ fn create_blocking_thread() {
100
.spawn(move || {
101
let wait_limit = Duration::from_millis(1000 + rand_sleep_ms);
102
103
- CURRENT_POOL_SIZE.fetch_add(1, Ordering::Relaxed);
+ CURRENT_POOL_SIZE.fetch_add(1, Ordering::SeqCst);
104
while let Ok(task) = POOL.receiver.recv_timeout(wait_limit) {
105
abort_on_panic(|| task.run());
106
calculate_dispatch_frequency();
107
}
108
- CURRENT_POOL_SIZE.fetch_sub(1, Ordering::Relaxed);
+ CURRENT_POOL_SIZE.fetch_sub(1, Ordering::SeqCst);
109
})
110
.expect("cannot start a dynamic thread driving blocking tasks");
111
0 commit comments