Class ThreadPoolExecutor

Declaration

class ThreadPoolExecutor(thread.ThreadPoolExecutor)

▶ def __init__(self, *args, **kwargs) override
inherited doc Initializes a new ThreadPoolExecutor instance.
source link
This method overrides distributed._concurrent_futures_thread.ThreadPoolExecutor.__init__.
```
Args:
    max_workers: The maximum number of threads that can be used to
        execute the given calls.
    thread_name_prefix: An optional name prefix to give our threads.
```
▶ def shutdown(self, wait=True, timeout=None) override
source link
This method overrides distributed._concurrent_futures_thread.ThreadPoolExecutor.shutdown.