diff --git a/src/fastserve/batching.py b/src/fastserve/batching.py
index 391edfc..a4e4284 100644
--- a/src/fastserve/batching.py
+++ b/src/fastserve/batching.py
@@ -139,8 +139,7 @@ def process(self, item: Any):
     def cancel(self):
         logger.info("Terminating Batch Processor...")
         self._cancel_signal.set()
-        self._thread.terminate()
-        # self._thread.join()
+        self._thread.join()
         logger.info("Batch Processor terminated!")
 
     def signal_handler(self, sig, frame):