From c5000c7bb417c0508289877c6e4a06cdf48a96ae Mon Sep 17 00:00:00 2001 From: Matthieu Jolimaitre Date: Thu, 7 Nov 2024 11:11:07 +0100 Subject: [PATCH] revert to processes --- src/okipy/strategies.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/okipy/strategies.py b/src/okipy/strategies.py index 5d48251..ed52429 100644 --- a/src/okipy/strategies.py +++ b/src/okipy/strategies.py @@ -1,5 +1,5 @@ from dataclasses import dataclass -from multiprocessing.pool import ThreadPool +from multiprocessing.pool import Pool from typing import Callable, TypeVar @@ -17,7 +17,7 @@ class RunStrategy: class Parallel(RunStrategy): procs: None | int = None def run_all(self, items: list[T], oper: Callable[[T], O]) -> list[O]: - return ThreadPool(self.procs).map(oper, items) + return Pool(self.procs).map(oper, items) class Sequential(RunStrategy):