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