diff --git a/pympipool/shared/executorbase.py b/pympipool/shared/executorbase.py
index c950eae1..232367fa 100644
--- a/pympipool/shared/executorbase.py
+++ b/pympipool/shared/executorbase.py
@@ -54,6 +54,7 @@ def shutdown(self, wait=True, *, cancel_futures=False):
             cancel_items_in_queue(que=self._future_queue)
         self._future_queue.put({"shutdown": True, "wait": wait})
         self._process.join()
+        self._future_queue.join()
 
     def __len__(self):
         return self._future_queue.qsize()