fix: Force process termination (#14)

Author: xmnlab

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()