From 8d32ac5151dc5088491ccf401d2917043fa19a8c Mon Sep 17 00:00:00 2001 From: sreedevk Date: Sun, 6 Jul 2025 13:16:25 +0000 Subject: [PATCH] fix: proc count decrement added --- src/pipeline/scanner.rs | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/pipeline/scanner.rs b/src/pipeline/scanner.rs index 8471f30..79d9226 100644 --- a/src/pipeline/scanner.rs +++ b/src/pipeline/scanner.rs @@ -39,6 +39,7 @@ impl Scanner { self.proc_count.fetch_add(1, Relaxed); let copy_of_queue = self.proc_queue.clone(); let copy_of_files = self.files.clone(); + let copy_of_proc_count = self.proc_count.clone(); self.threadpool.execute(move || { if let Ok((files, dirs)) = Self::scan(path) { @@ -46,6 +47,7 @@ impl Scanner { let mut f = copy_of_files.lock().unwrap(); q.extend(files); f.extend(dirs); + copy_of_proc_count.fetch_sub(1, Relaxed); } }); }