waiting for threads to finish work

1 files changed, 4 insertions, 0 deletions

diff --git a/src/files.rs b/src/files.rs
index 849de77..8db0f64 100644
--- a/src/files.rs
+++ b/src/files.rs
@@ -186,6 +186,10 @@ pub fn reencode_files(conn: Connection, handler: Arc<AtomicBool>, threads: usize
         });
     }
 
+    while *thread_counter.read().unwrap() != 0 {
+        sleep(time::Duration::from_millis(100));
+    }
+
     #[cfg(not(test))]
     {
         if handler.load(Ordering::SeqCst) {