ThreadPoolExecutor(label: str = 'threads', max_threads: int = 2, thread_name_prefix: str = '', storage_access: List[Any] = None, working_dir: Optional[str] = None, managed: bool = True)¶
A thread-based executor.
- max_threads (int) – Number of threads. Default is 2.
- thread_name_prefix (string) – Thread name prefix (only supported in python v3.6+).
- storage_access (list of
Staging) – Specifications for accessing data this executor remotely.
- managed (bool) – If True, parsl will control dynamic scaling of this executor, and be responsible. Otherwise, this is managed by the user.
__init__(label: str = 'threads', max_threads: int = 2, thread_name_prefix: str = '', storage_access: List[Any] = None, working_dir: Optional[str] = None, managed: bool = True)¶
Initialize self. See help(type(self)) for accurate signature.
__init__(label, max_threads, …)
Scale in the number of active blocks by specified amount.
Scales out the number of active workers by 1.
Shutdown the ThreadPool.
Start the executor.
Submits work to the thread pool.
Address to the Hub for monitoring.
Port to the Hub for monitoring.
Path to the run directory.
Specify if scaling is enabled.