1
- import threading
2
1
from typing import Optional
3
2
from concurrent .futures import (
4
3
Executor as FutureExecutor ,
12
11
import cloudpickle
13
12
14
13
from pympipool .shared .communication import interface_bootup
14
+ from pympipool .shared .thread import RaisingThread
15
15
16
16
17
17
class ExecutorBase (FutureExecutor ):
@@ -76,7 +76,7 @@ def shutdown(self, wait: bool = True, *, cancel_futures: bool = False):
76
76
self ._process = None
77
77
self ._future_queue = None
78
78
79
- def _set_process (self , process : threading . Thread ):
79
+ def _set_process (self , process : RaisingThread ):
80
80
self ._process = process
81
81
self ._process .start ()
82
82
@@ -89,7 +89,7 @@ def __del__(self):
89
89
except (AttributeError , RuntimeError ):
90
90
pass
91
91
92
- def _set_process (self , process : threading . Thread ):
92
+ def _set_process (self , process : RaisingThread ):
93
93
self ._process = process
94
94
self ._process .start ()
95
95
@@ -121,7 +121,7 @@ def shutdown(self, wait: bool = True, *, cancel_futures: bool = False):
121
121
self ._process = None
122
122
self ._future_queue = None
123
123
124
- def _set_process (self , process : threading . Thread ):
124
+ def _set_process (self , process : RaisingThread ):
125
125
self ._process = process
126
126
for process in self ._process :
127
127
process .start ()
0 commit comments