| /external/python/futures/concurrent/futures/ |
| __init__.py | 16 as_completed)
|
| _base.py | 59 """Provides the event that wait() and as_completed() block on."""
74 """Used by as_completed()."""
198 def as_completed(fs, timeout=None): function
526 to as_completed() or wait()) are notified and False is returned.
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| __init__.py | 17 as_completed)
29 'as_completed',
|
| _base.py | 57 """Provides the event that wait() and as_completed() block on."""
72 """Used by as_completed()."""
196 def as_completed(fs, timeout=None): function
477 to as_completed() or wait()) are notified and False is returned.
|
| /external/python/futures/ |
| crawl.py | 13 from concurrent.futures import (as_completed, ThreadPoolExecutor,
47 for future in as_completed(future_to_url):
|
| test_futures.py | 425 completed = set(futures.as_completed(
441 for future in futures.as_completed(
460 completed = [f for f in futures.as_completed([future1,future1])]
|
| /external/python/cpython3/Lib/test/ |
| test_concurrent_futures.py | 574 completed = set(futures.as_completed(
590 for future in futures.as_completed(
611 f for f in futures.as_completed(itertools.repeat(future1, 3))
623 for future in futures.as_completed(futures_list, timeout=0):
630 for future in futures.as_completed(futures_list):
643 list(futures.as_completed(futures_list, timeout=0))
[all...] |
| /external/yapf/yapf/ |
| __init__.py | 247 for future in concurrent.futures.as_completed(future_formats):
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_tasks.py | [all...] |
| /external/python/cpython3/Lib/asyncio/ |
| tasks.py | 6 'wait', 'wait_for', 'as_completed', 'sleep',
328 # wait() and as_completed() similar to those in PEP 3148.
488 def as_completed(fs, *, loop=None, timeout=None): function
497 for f in as_completed(fs):
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| _rpc_test.py | 418 futures.as_completed(response_futures),
[all...] |
