Searched refs:as_completed (Results 1 – 21 of 21) sorted by relevance
| /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/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 | 17 as_completed)
|
| D | _base.py | 196 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.7.1rc2.rst | 96 :func:`as_completed`, in order to prevent timeouts from deviating when the
|
| D | 3.6.3rc1.rst | 399 The ``map()`` and ``as_completed()`` iterators in ``concurrent.futures`` now
|
| D | 3.7.0a1.rst | 1757 The ``map()`` and ``as_completed()`` iterators in ``concurrent.futures`` now
|
| /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/Lib/test/ |
| D | 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))
|
| /external/python/cpython3/Doc/library/ |
| D | concurrent.futures.rst | 187 for future in concurrent.futures.as_completed(future_to_url):
365 :func:`as_completed` or :func:`wait`) will be woken up.
428 .. function:: as_completed(fs, timeout=None)
434 :func:`as_completed` is called will be yielded first. The returned iterator
437 original call to :func:`as_completed`. *timeout* can be an int or float. If
|
| D | asyncio-api-index.rst | 54 * - ``for in`` :func:`as_completed`
|
| D | asyncio-future.rst | 250 :func:`concurrent.futures.as_completed` functions.
|
| D | asyncio-task.rst | 551 .. function:: as_completed(aws, \*, loop=None, timeout=None)
563 for f in as_completed(aws):
|
| /external/yapf/yapf/ |
| D | __init__.py | 247 for future in concurrent.futures.as_completed(future_formats):
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 1207 for f in asyncio.as_completed([b, c, a], loop=loop):
1236 for f in asyncio.as_completed([a, b], timeout=0.12, loop=loop):
1269 for f in asyncio.as_completed([a], timeout=1, loop=loop):
1287 futs = list(asyncio.as_completed(fs, loop=loop))
1312 futs = list(asyncio.as_completed(fs, loop=loop))
1328 for f in asyncio.as_completed([c, c, coro('spam')],
1822 asyncio.as_completed(fut, loop=self.loop))
1825 asyncio.as_completed(coro, loop=self.loop))
|
| /external/python/cpython3/Lib/asyncio/ |
| D | tasks.py | 488 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/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
|