Searched refs:as_completed (Results 1 - 5 of 5) sorted by relevance
| /third_party/python/Lib/concurrent/futures/ |
| H A D | __init__.py | 18 as_completed)
30 'as_completed',
|
| H A D | _base.py | 60 """Provides the event that wait() and as_completed() block on."""
75 """Used by as_completed()."""
199 def as_completed(fs, timeout=None): function
504 to as_completed() or wait()) are notified and False is returned.
|
| /third_party/python/Lib/test/ |
| H A D | test_concurrent_futures.py | 746 completed = set(futures.as_completed(
762 for future in futures.as_completed(
783 f for f in futures.as_completed(itertools.repeat(future1, 3))
795 for future in futures.as_completed(futures_list, timeout=0):
803 for future in futures.as_completed(futures_list):
817 list(futures.as_completed(futures_list, timeout=0))
|
| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_tasks.py | 1394 for f in asyncio.as_completed([b, c, a]):
1419 for f in asyncio.as_completed([a, b], timeout=0.12):
1452 for f in asyncio.as_completed([a], timeout=1):
1472 futs = list(asyncio.as_completed(fs))
1499 futs = list(asyncio.as_completed(fs))
1517 for f in asyncio.as_completed([c, c, coro('spam')]):
1534 futs = asyncio.as_completed([a])
1545 futs = list(asyncio.as_completed([coro()]))
1995 # as_completed() expects a list of futures, not a future instance
1997 asyncio.as_completed(fu
[all...] |
| /third_party/python/Lib/asyncio/ |
| H A D | tasks.py | 6 'wait', 'wait_for', 'as_completed', 'sleep',
382 # wait() and as_completed() similar to those in PEP 3148.
558 def as_completed(fs, *, timeout=None): function
567 for f in as_completed(fs):
|
Completed in 8 milliseconds