smolkik_adm/deduplicator
1
0
Fork 0
mirror of https://github.com/sreedevk/deduplicator.git synced 2026-08-31 20:45:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: proc count decrement added

Browse Source
This commit is contained in:
sreedevk
2025-07-06 13:16:25 +00:00
parent 0c70e27835
commit 8d32ac5151
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipeline/scanner.rs
View File

@@ -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);
}
});
}