fz0x1/HPI
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

core: set _max_workers for dummy concurrent pool

Browse source
This commit is contained in:
Dima Gerasimov 2021-04-04 10:00:20 +01:00 • committed by karlicoss
parent 4b4cb7cb5b
commit 393ed0d9ce
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
my/core/common.py
View file

@ -602,9 +602,9 @@ def assert_subpackage(name: str) -> None:
# https://stackoverflow.com/a/10436851/706389 # https://stackoverflow.com/a/10436851/706389
from concurrent.futures import Future, Executor from concurrent.futures import Future, Executor
class DummyExecutor(Executor): class DummyExecutor(Executor):
def __init__(self, workers: Optional[int]=0) -> None: def __init__(self, max_workers: Optional[int]=1) -> None:
self._shutdown = False self._shutdown = False
assert workers == 0 self._max_workers = max_workers
def submit(self, fn, *args, **kwargs) -> Future: def submit(self, fn, *args, **kwargs) -> Future:
if self._shutdown: if self._shutdown: