|
|
|
|
|
|
|
|
|
|
|
"""Execute computations asynchronously using threads or processes.""" |
|
|
|
|
|
__author__ = 'Brian Quinlan (brian@sweetapp.com)' |
|
|
|
|
|
from concurrent.futures._base import (FIRST_COMPLETED, |
|
|
FIRST_EXCEPTION, |
|
|
ALL_COMPLETED, |
|
|
CancelledError, |
|
|
TimeoutError, |
|
|
InvalidStateError, |
|
|
BrokenExecutor, |
|
|
Future, |
|
|
Executor, |
|
|
wait, |
|
|
as_completed) |
|
|
|
|
|
__all__ = ( |
|
|
'FIRST_COMPLETED', |
|
|
'FIRST_EXCEPTION', |
|
|
'ALL_COMPLETED', |
|
|
'CancelledError', |
|
|
'TimeoutError', |
|
|
'BrokenExecutor', |
|
|
'Future', |
|
|
'Executor', |
|
|
'wait', |
|
|
'as_completed', |
|
|
'ProcessPoolExecutor', |
|
|
'ThreadPoolExecutor', |
|
|
) |
|
|
|
|
|
|
|
|
def __dir__(): |
|
|
return __all__ + ('__author__', '__doc__') |
|
|
|
|
|
|
|
|
def __getattr__(name): |
|
|
global ProcessPoolExecutor, ThreadPoolExecutor |
|
|
|
|
|
if name == 'ProcessPoolExecutor': |
|
|
from .process import ProcessPoolExecutor as pe |
|
|
ProcessPoolExecutor = pe |
|
|
return pe |
|
|
|
|
|
if name == 'ThreadPoolExecutor': |
|
|
from .thread import ThreadPoolExecutor as te |
|
|
ThreadPoolExecutor = te |
|
|
return te |
|
|
|
|
|
raise AttributeError(f"module {__name__} has no attribute {name}") |
|
|
|
