diff --git a/sf-writer/src/main.cpp b/sf-writer/src/main.cpp
index 92f6e8a..8a1c6f8 100644
--- a/sf-writer/src/main.cpp
+++ b/sf-writer/src/main.cpp
@@ -150,7 +150,11 @@ int main (int argc, char *argv[])
 
     writer.close_file();
 
-    //wait till receive thread is finished
-    replay_receive_thread.join(); 
+    for (auto& reading_thread :reading_threads) {
+        if (reading_thread.joinable()) {
+            reading_thread.join();
+        }
+    }
+
     return 0;
 }