perf: stats create non-zero bounded channels

dathere · Feb 2, 2025 · 6965c90 · 6965c90
1 parent 7495baa
commit 6965c90
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/cmd/stats.rs b/src/cmd/stats.rs
@@ -1057,7 +1057,7 @@ impl Args {
         let nchunks = util::num_of_chunks(idx_count as usize, chunk_size);
 
         let pool = ThreadPool::new(njobs);
-        let (send, recv) = crossbeam_channel::bounded(0);
+        let (send, recv) = crossbeam_channel::bounded(nchunks);
         for i in 0..nchunks {
             let (send, args, sel) = (send.clone(), self.clone(), sel.clone());
             pool.execute(move || {