Searched refs:futures (Results 1 – 25 of 80) sorted by relevance
1234
| /third_party/python/Lib/test/ |
| D | test_concurrent_futures.py | 24 from concurrent import futures
25 from concurrent.futures._base import (
28 from concurrent.futures.process import BrokenProcessPool, _check_system_limits
147 futures = [self.executor.submit(time.sleep, 0.1)
149 for f in futures:
154 executor_type = futures.ThreadPoolExecutor
158 executor_type = futures.ProcessPoolExecutor
172 executor_type = futures.ProcessPoolExecutor
184 executor_type = futures.ProcessPoolExecutor
228 futures = [self.executor.submit(get_init_status)
[all …]
|
| D | test_genericalias.py | 10 from concurrent.futures import Future
11 from concurrent.futures.thread import _WorkItem
|
| /third_party/python/Doc/library/ |
| D | concurrent.futures.rst | 1 :mod:`concurrent.futures` --- Launching parallel tasks
4 .. module:: concurrent.futures
9 **Source code:** :source:`Lib/concurrent/futures/thread.py`
10 and :source:`Lib/concurrent/futures/process.py`
14 The :mod:`concurrent.futures` module provides a high-level interface for
50 The returned iterator raises a :exc:`concurrent.futures.TimeoutError`
73 when the currently pending futures are done executing. Calls to
78 pending futures are done executing and the resources associated with the
81 freed when all pending futures are done executing. Regardless of the
83 pending futures are done executing.
[all …]
|
| D | asyncio-future.rst | 4 .. _asyncio-futures:
10 **Source code:** :source:`Lib/asyncio/futures.py`,
70 Wrap a :class:`concurrent.futures.Future` object in a
257 :class:`concurrent.futures.Future`. Key differences include:
259 - unlike asyncio Futures, :class:`concurrent.futures.Future`
274 :func:`concurrent.futures.wait` and
275 :func:`concurrent.futures.as_completed` functions.
278 but :func:`concurrent.futures.cancel` does not.
|
| D | concurrent.rst | 6 * :mod:`concurrent.futures` -- Launching parallel tasks
|
| D | concurrency.rst | 20 concurrent.futures.rst
|
| D | asyncio-dev.rst | 91 :class:`concurrent.futures.Future` to access the result::
106 :class:`concurrent.futures.ThreadPoolExecutor` to execute
118 with a :class:`concurrent.futures.ProcessPoolExecutor` to execute
|
| D | asyncio.rst | 57 * :ref:`bridge <asyncio-futures>` callback-based libraries and code
|
| /third_party/python/Lib/asyncio/ |
| D | tasks.py | 12 import concurrent.futures
25 from . import futures
61 if futures._get_loop(t) is loop and not t.done()}
74 class Task(futures._PyFuture): # Inherit Python Task implementation
116 if self._state == futures._PENDING and self._log_destroy_pending:
255 if futures._get_loop(result) is not self._loop:
344 FIRST_COMPLETED = concurrent.futures.FIRST_COMPLETED
345 FIRST_EXCEPTION = concurrent.futures.FIRST_EXCEPTION
346 ALL_COMPLETED = concurrent.futures.ALL_COMPLETED
365 if futures.isfuture(fs) or coroutines.iscoroutine(fs):
[all …]
|
| D | __main__.py | 4 import concurrent.futures
11 from . import futures
23 future = concurrent.futures.Future()
51 futures._chain_future(repl_future, future)
|
| D | futures.py | 7 import concurrent.futures
317 if exc_class is concurrent.futures.CancelledError:
319 elif exc_class is concurrent.futures.TimeoutError:
321 elif exc_class is concurrent.futures.InvalidStateError:
370 concurrent.futures.Future):
373 concurrent.futures.Future):
408 assert isinstance(future, concurrent.futures.Future), \
|
| D | __init__.py | 12 from .futures import *
27 futures.__all__ +
|
| D | base_events.py | 18 import concurrent.futures
42 from . import futures
191 futures._get_loop(fut).stop()
424 return futures.Future(loop=self)
619 new_task = not futures.isfuture(future)
808 executor = concurrent.futures.ThreadPoolExecutor(
812 return futures.wrap_future(
816 if not isinstance(executor, concurrent.futures.ThreadPoolExecutor):
|
| D | windows_events.py | 20 from . import futures
48 class _OverlappedFuture(futures.Future):
96 class _BaseWaitHandleFuture(futures.Future):
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_futures.py | 3 import concurrent.futures
12 from asyncio import futures
377 from asyncio.futures import _copy_future_state
478 ex = concurrent.futures.ThreadPoolExecutor(1)
495 ex = concurrent.futures.ThreadPoolExecutor(1)
506 ex = concurrent.futures.ThreadPoolExecutor(1)
520 ex = concurrent.futures.ThreadPoolExecutor(1)
529 f1 = concurrent.futures.Future()
537 f1 = concurrent.futures.Future()
593 futures._set_result_unless_cancelled(fut, 2)
[all …]
|
| D | test_tasks.py | 21 from asyncio import futures
2964 @unittest.skipUnless(hasattr(futures, '_CFuture') and
2971 Future = getattr(futures, '_CFuture', None)
2995 @unittest.skipUnless(hasattr(futures, '_CFuture') and
3002 Future = getattr(futures, '_CFuture', None)
3011 Future = futures._PyFuture
3014 @unittest.skipUnless(hasattr(futures, '_CFuture'),
3019 Future = getattr(futures, '_CFuture', None)
3028 Future = futures._PyFuture
3031 @unittest.skipUnless(hasattr(futures, '_CFuture'),
[all …]
|
| D | utils.py | 33 from asyncio import futures
117 raise futures.TimeoutError()
|
| /third_party/rust/crates/cxx/book/src/ |
| D | async.md | 28 channel (such as [`futures::channel::oneshot`]) represented in an opaque Rust
31 [`futures::channel::oneshot`]: https://docs.rs/futures/0.3.8/futures/channel/oneshot/index.html
36 use futures::channel::oneshot;
|
| /third_party/python/Lib/test/test_importlib/partial/ |
| D | cfimport.py | 13 from concurrent.futures import ThreadPoolExecutor
20 from concurrent.futures.thread import ThreadPoolExecutor
|
| /third_party/python/Lib/concurrent/futures/ |
| D | _base.py | 146 def __init__(self, futures): argument
147 self.futures = sorted(futures, key=id)
150 for future in self.futures:
154 for future in self.futures:
|
| D | __init__.py | 8 from concurrent.futures._base import (FIRST_COMPLETED,
|
| D | thread.py | 8 from concurrent.futures import _base
|
| /third_party/python/Misc/NEWS.d/ |
| D | 3.6.3.rst | 7 Re-allow arbitrary iterables in `concurrent.futures.as_completed()`. Fixes
|
| /third_party/python/Lib/distutils/command/ |
| D | build_ext.py | 456 from concurrent.futures import ThreadPoolExecutor
465 futures = [executor.submit(self.build_extension, ext)
467 for ext, fut in zip(self.extensions, futures):
|
| /third_party/python/Lib/ |
| D | compileall.py | 88 from concurrent.futures.process import _check_system_limits
94 from concurrent.futures import ProcessPoolExecutor
|
1234