diff --git a/src/retsu/core.py b/src/retsu/core.py
index 2635654..7579ead 100644
--- a/src/retsu/core.py
+++ b/src/retsu/core.py
@@ -58,6 +58,7 @@ def stop(self) -> None:
 
         for i in range(self.workers):
             p = self.processes[i]
+            p.terminate()
             p.join()
 
         # self.queue_in.close()