From 5296ce56521ca4970c4867336972e4d610b0bc03 Mon Sep 17 00:00:00 2001
From: Zhaosheng Pan <zhaosheng.pan@sololand.moe>
Date: Mon, 26 Aug 2024 21:17:09 +0800
Subject: [PATCH] feat: improve

---
 src/main.rs | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index 774e749..b009ed9 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -89,7 +89,6 @@ fn push(queues: &[PathQueue], index: usize, path: PathBuf) -> Result<()> {
 }
 
 fn breadth_first_traverse(prog: &str, cwd: &Path, opt: &Options, queues: &[PathQueue], index: usize, counter: &AtomicUsize) -> Result<()> {
-    let queue = &queues[index];
     loop {
         let path = pop_or_steal(queues, index)?;
         if let Some(path) = path {
@@ -147,7 +146,7 @@ fn breadth_first_traverse(prog: &str, cwd: &Path, opt: &Options, queues: &[PathQ
         } else if counter.load(Ordering::Acquire) == 0 {
             break;
         } else {
-            thread::sleep(Duration::from_millis(13));
+            thread::sleep(Duration::from_millis(7));
         }
     }
     Ok(())
@@ -260,8 +259,7 @@ fn main() {
 
     let mut queues = Vec::new();
     for _ in 0..num_threads {
-        let q = PathQueue::new((1024 * 512 / num_threads) as u32,
-                                                         (1024 * 512 / num_threads) as u32);
+        let q = PathQueue::new((1024 * 512 / num_threads) as u32, (1024 * 512 / num_threads) as u32);
         if let Ok(q) = q {
             queues.push(q);
         } else {