pfun icon indicating copy to clipboard operation
pfun copied to clipboard

Allow global thread and process pool executors

Open suned opened this issue 3 years ago • 0 comments

Currently each effect is interpreted using its own process and thread pools. It would be preferable to enable the caller to control the lifecycle of these pools. Concretely, we could change the signature of functions that introduce the dependency on a thread or process pool to e.g:

def from_cpu_bound_callable(f: Callable[[R], Either[E, A]]) -> Effect[Intersection[R, HasProcessPool], E, A]: ...

Where HasProcessPool is defined as:

from typing import Protocol


class HasProcessPool(Protocol):
    pool: ProcessPoolExecutor

suned avatar May 18 '22 12:05 suned