| /external/python/futures/ |
| D | crawl.py | 13 from concurrent.futures import (as_completed, ThreadPoolExecutor,
47 for future in as_completed(future_to_url):
|
| D | 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/llvm-project/llvm/utils/ |
| D | update_test_prefix.py | 6 from concurrent.futures import ThreadPoolExecutor, as_completed
47 for i in as_completed(t):
|
| /external/python/futures/concurrent/futures/ |
| D | __init__.py | 16 as_completed)
|
| D | _base.py | 198 def as_completed(fs, timeout=None): function
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | __init__.py | 18 as_completed)
|
| D | _base.py | 201 def as_completed(fs, timeout=None): function
|
| /external/python/cpython3/Misc/NEWS.d/ |
| D | 3.6.3.rst | 7 Re-allow arbitrary iterables in `concurrent.futures.as_completed()`. Fixes
|
| D | 3.6.3rc1.rst | 398 The ``map()`` and ``as_completed()`` iterators in ``concurrent.futures`` now
|
| D | 3.7.0a1.rst | 1756 The ``map()`` and ``as_completed()`` iterators in ``concurrent.futures`` now
|
| D | 3.8.0a1.rst | 2992 :func:`as_completed`, in order to prevent timeouts from deviating when the
|
| /external/python/futures/docs/ |
| D | index.rst | 139 for future in futures.as_completed(future_to_url):
278 on the :class:`Future` completing (i.e. through :func:`as_completed` or
336 .. function:: as_completed(fs, timeout=None)
342 before :func:`as_completed` is called will be yielded first. The returned
345 original call to :func:`as_completed`. *timeout* can be an int or float.
|
| /external/python/cpython3/Doc/library/ |
| D | concurrent.futures.rst | 208 for future in concurrent.futures.as_completed(future_to_url):
396 :func:`as_completed` or :func:`wait`) will be woken up.
469 .. function:: as_completed(fs, timeout=None)
475 :func:`as_completed` is called will be yielded first. The returned iterator
478 original call to :func:`as_completed`. *timeout* can be an int or float. If
|
| D | asyncio-api-index.rst | 57 * - ``for in`` :func:`as_completed`
|
| D | asyncio-future.rst | 260 :func:`concurrent.futures.as_completed` functions.
|
| D | asyncio-task.rst | 593 .. function:: as_completed(aws, \*, loop=None, timeout=None)
608 for coro in as_completed(aws):
|
| /external/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 694 completed = set(futures.as_completed(
710 for future in futures.as_completed(
731 f for f in futures.as_completed(itertools.repeat(future1, 3))
743 for future in futures.as_completed(futures_list, timeout=0):
750 for future in futures.as_completed(futures_list):
763 list(futures.as_completed(futures_list, timeout=0))
|
| /external/yapf/yapf/ |
| D | __init__.py | 247 for future in concurrent.futures.as_completed(future_formats):
|
| /external/oss-fuzz/infra/build/functions/ |
| D | update_build_status.py | 184 for future in concurrent.futures.as_completed(futures):
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 1606 for f in asyncio.as_completed([b, c, a], loop=loop):
1636 for f in asyncio.as_completed([a, b], timeout=0.12, loop=loop):
1670 for f in asyncio.as_completed([a], timeout=1, loop=loop):
1691 futs = list(asyncio.as_completed(fs, loop=loop))
1717 futs = list(asyncio.as_completed(fs, loop=loop))
1737 for f in asyncio.as_completed([c, c, coro('spam')],
2213 asyncio.as_completed(fut, loop=self.loop))
2216 asyncio.as_completed(coro, loop=self.loop))
|
| /external/python/cpython3/Lib/asyncio/ |
| D | tasks.py | 559 def as_completed(fs, *, loop=None, timeout=None): function
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _rpc_test.py | 418 futures.as_completed(response_futures),
|
| /external/python/cpython3/Doc/whatsnew/ |
| D | 3.8.rst | 1682 :func:`asyncio.wait_for`, :func:`asyncio.wait`, :func:`asyncio.as_completed`,
|
| /external/python/cpython3/Misc/ |
| D | HISTORY | 2277 - Issue #20566: Change asyncio.as_completed() to use a Queue, to
2287 TimerHandle; as_completed() and wait() raise TypeError if the passed
2465 in gather(), wait(), as_completed(); use a bytearray for buffering
2494 - Issue #20367: Fix behavior of concurrent.futures.as_completed() for
|