From eba13b5701069f30547cbc3556a9e081e86c2244 Mon Sep 17 00:00:00 2001 From: Jan Janssen Date: Tue, 31 Oct 2023 12:17:03 +0100 Subject: [PATCH 1/2] Fix interface shutdown --- pympipool/shared/executorbase.py | 1 + 1 file changed, 1 insertion(+) diff --git a/pympipool/shared/executorbase.py b/pympipool/shared/executorbase.py index c950eae1..cf1a27c5 100644 --- a/pympipool/shared/executorbase.py +++ b/pympipool/shared/executorbase.py @@ -53,6 +53,7 @@ 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() def __len__(self): From 7d7bd99d7113e740adffad5e7b08b18edd05e893 Mon Sep 17 00:00:00 2001 From: Jan Janssen Date: Tue, 31 Oct 2023 12:26:38 +0100 Subject: [PATCH 2/2] Fix order --- pympipool/shared/executorbase.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()