switch to thread

Signed-off-by: Sylvain Hellegouarch <sh@defuze.org>

Author: Lawouach

CHANGELOG.md

@@ -2,7 +2,16 @@
 
 ## [Unreleased][]
 
-[Unreleased]: https://github.com/chaostoolkit/chaostoolkit-addons/compare/0.8.0...HEAD
+[Unreleased]: https://github.com/chaostoolkit/chaostoolkit-addons/compare/0.8.1...HEAD
+
+## [0.8.1][]
+
+[0.8.1]: https://github.com/chaostoolkit/chaostoolkit-addons/compare/0.8.0...0.8.1
+
+### Changed
+
+- Switched to regular thread to check if must interrupted as the future
+  executor is bit painful when it comes to exiting the program
 
 ## [0.8.0][]
 

chaosaddons/controls/safeguards.py

@@ -151,7 +151,7 @@ def prepare(self, probes: List[Probe]) -> None:
         self.now = ThreadPoolExecutor(max_workers=now_count or 1)
         self.once = ThreadPoolExecutor(max_workers=once_count or 1)
         self.repeating = ThreadPoolExecutor(max_workers=repeating_count or 1)
-        self.interrupter = ThreadPoolExecutor(max_workers=1)
+        self.interrupter = threading.Thread(None, self._wait_interruption)
         self._setup = True
 
     def run(self, experiment: Experiment, probes: List[Probe],
@@ -164,7 +164,8 @@ def run(self, experiment: Experiment, probes: List[Probe],
         or not), then this call blocks until all these pre-check safeguards
         are completed.
         """
-        self.interrupter.submit(self._wait_interruption)
+        self.interrupter.start()
+
         for p in probes:
             f = None
             if p.get("frequency"):

setup.py

@@ -5,5 +5,5 @@
     setup(
         use_scm_version=True,
         name="chaostoolkit-addons",
-        version="0.8.0",
+        version="0.8.1",
     )