Lines Matching defs:self
90 def __init__(self, nworkers=0, name="Pool"): argument
99 def apply(self, func, args=(), kwds=dict()): argument
104 def map(self, func, iterable, chunksize=None): argument
114 def imap(self, func, iterable, chunksize=1): argument
132 def imap_unordered(self, func, iterable, chunksize=1): argument
141 def apply_async(self, func, args=(), kwds=dict(), callback=None): argument
156 def map_async(self, func, iterable, chunksize=None, callback=None): argument
171 def imap_async(self, func, iterable, chunksize=None, callback=None): argument
187 def imap_unordered_async(self, func, iterable, chunksize=None, argument
204 def close(self): argument
211 def terminate(self): argument
218 def join(self): argument
223 def __enter__(self): argument
226 def __exit__(self, exc_type, exc_value, traceback): argument
229 def __del__(self): argument
233 def _create_sequences(self, func, iterable, chunksize, collector): argument
269 def __init__(self, func, args, kwds, apply_result): argument
280 def __call__(self): argument
298 def __init__(self, jobs): argument
301 def __call__(self): argument
318 def __init__(self, collector=None, callback=None): argument
337 def get(self, timeout=None): argument
350 def wait(self, timeout=None): argument
356 def ready(self): argument
360 def successful(self): argument
367 def _set_value(self, value): argument
384 def _set_exception(self): argument
405 def __init__(self, to_notify): argument
412 def register_result(self, apply_result): argument
421 def notify_ready(self, apply_result): argument
430 def _get_result(self, idx, timeout=None): argument
441 def __iter__(self): argument
452 def __init__(self, collector): argument
457 def __iter__(self): argument
460 def next(self, timeout=None): argument
477 def __next__(self): argument
487 def __init__(self, to_notify=None): argument
497 def register_result(self, apply_result): argument
506 def _get_result(self, idx, timeout=None): argument
534 def notify_ready(self, apply_result=None): argument
561 def __init__(self, to_notify=None, as_iterator=True): argument
576 def register_result(self, apply_result): argument
586 def _get_result(self, idx, timeout=None): argument
599 def notify_ready(self, apply_result): argument