Home
last modified time | relevance | path

Searched refs:futures (Results 1 - 25 of 29) sorted by relevance

12

/third_party/python/Lib/test/
H A Dtest_concurrent_futures.py25 from concurrent import futures namespace
26 from concurrent.futures._base import (
29 from concurrent.futures.process import BrokenProcessPool, _check_system_limits
83 logger = logging.getLogger('concurrent.futures')
87 time.sleep(0.1) # let some futures be scheduled
151 executor_type = futures.ThreadPoolExecutor
155 executor_type = futures.ProcessPoolExecutor
169 executor_type = futures.ProcessPoolExecutor
181 executor_type = futures.ProcessPoolExecutor
225 futures
[all...]
H A Dtest_genericalias.py10 from concurrent.futures import Future
11 from concurrent.futures.thread import _WorkItem
H A Dtest_context.py1 import concurrent.futures namespace
356 tp = concurrent.futures.ThreadPoolExecutor(max_workers=10)
/third_party/python/Lib/asyncio/
H A Dtasks.py12 import concurrent.futures namespace
26 from . import futures namespace
62 if futures._get_loop(t) is loop and not t.done()}
78 class Task(futures._PyFuture): # Inherit Python Task implementation
124 if self._state == futures._PENDING and self._log_destroy_pending:
290 if futures._get_loop(result) is not self._loop:
348 # instead of `__next__()`, which is slower for futures
384 FIRST_COMPLETED = concurrent.futures.FIRST_COMPLETED
385 FIRST_EXCEPTION = concurrent.futures.FIRST_EXCEPTION
386 ALL_COMPLETED = concurrent.futures
[all...]
H A D__main__.py4 import concurrent.futures namespace
11 from . import futures namespace
23 future = concurrent.futures.Future()
51 futures._chain_future(repl_future, future)
H A Dfutures.py7 import concurrent.futures namespace
31 """This class is *almost* compatible with concurrent.futures.Future.
44 methods in the concurrent.futures package.
320 if exc_class is concurrent.futures.CancelledError:
322 elif exc_class is concurrent.futures.TimeoutError:
324 elif exc_class is concurrent.futures.InvalidStateError:
331 """Copy state from a future to a concurrent.futures.Future."""
348 The other Future may be a concurrent.futures.Future.
366 """Chain two futures so that when one completes, so does the other.
370 Compatible with both asyncio.Future and concurrent.futures
[all...]
H A D__init__.py12 from .futures import *
29 futures.__all__ +
H A Dbase_events.py18 import concurrent.futures namespace
42 from . import futures namespace
187 futures._get_loop(fut).stop()
427 return futures.Future(loop=self)
631 new_task = not futures.isfuture(future)
824 executor = concurrent.futures.ThreadPoolExecutor(
828 return futures.wrap_future(
832 if not isinstance(executor, concurrent.futures.ThreadPoolExecutor):
H A Dwindows_events.py20 from . import futures namespace
48 class _OverlappedFuture(futures.Future):
96 class _BaseWaitHandleFuture(futures.Future):
856 # Remove unregistered futures
875 # Nothing to do with cancelled futures
H A Dunix_events.py22 from . import futures namespace
489 self._loop.call_soon(futures._set_result_unless_cancelled,
639 self._loop.call_soon(futures._set_result_unless_cancelled,
H A Dselector_events.py24 from . import futures namespace
940 self._loop.call_soon(futures._set_result_unless_cancelled,
1149 self._loop.call_soon(futures._set_result_unless_cancelled,
H A Dproactor_events.py19 from . import futures namespace
70 self._loop.call_soon(futures._set_result_unless_cancelled,
/third_party/python/Lib/test/test_asyncio/
H A Dtest_futures.py1 """Tests for futures.py."""
3 import concurrent.futures namespace
12 from asyncio import futures namespace
378 from asyncio.futures import _copy_future_state
479 ex = concurrent.futures.ThreadPoolExecutor(1)
496 ex = concurrent.futures.ThreadPoolExecutor(1)
505 ex = concurrent.futures.ThreadPoolExecutor(1)
519 ex = concurrent.futures.ThreadPoolExecutor(1)
526 f1 = concurrent.futures.Future()
534 f1 = concurrent.futures
[all...]
H A Dtest_tasks.py20 from asyncio import futures namespace
1995 # as_completed() expects a list of futures, not a future instance
2006 # wait() expects a list of futures, not a future instance
2554 @unittest.skipUnless(hasattr(futures, '_CFuture') and
2561 Future = getattr(futures, '_CFuture', None)
2585 @unittest.skipUnless(hasattr(futures, '_CFuture') and
2592 Future = getattr(futures, '_CFuture', None)
2601 Future = futures._PyFuture
2604 @unittest.skipUnless(hasattr(futures, '_CFuture'),
2609 Future = getattr(futures, '_CFutur
[all...]
H A Dutils.py33 from asyncio import futures namespace
117 raise futures.TimeoutError()
/third_party/python/Lib/test/test_importlib/partial/
H A Dcfimport.py13 from concurrent.futures import ThreadPoolExecutor
20 from concurrent.futures.thread import ThreadPoolExecutor
34 sys.modules.pop('concurrent.futures', None)
35 sys.modules.pop('concurrent.futures.thread', None)
/third_party/python/Lib/concurrent/futures/
H A D_base.py17 # Possible future states (for internal use by the futures package).
42 # Logger for internal use by the futures package.
43 LOGGER = logging.getLogger("concurrent.futures")
144 def __init__(self, futures):
145 self.futures = sorted(futures, key=id)
148 for future in self.futures:
152 for future in self.futures:
179 Iterate on the list *fs*, yielding finished futures one by one in
200 """An iterator over the given futures tha
[all...]
H A D__init__.py8 from concurrent.futures._base import (FIRST_COMPLETED,
H A Dthread.py8 from concurrent.futures import _base
167 raise RuntimeError('cannot schedule new futures after shutdown')
169 raise RuntimeError('cannot schedule new futures after '
207 # Drain work queue and mark pending futures failed
221 # associated futures.
H A Dprocess.py49 from concurrent.futures import _base
367 # When only canceled futures remain in pending_work_items, our
369 # This makes sure we have some running futures or none at all.
511 # Cancel all pending futures and update pending_work_items
512 # to only have futures that are currently running.
709 # because futures in the call queue cannot be cancelled.
772 raise RuntimeError('cannot schedule new futures after shutdown')
774 raise RuntimeError('cannot schedule new futures after '
/third_party/python/Lib/distutils/command/
H A Dbuild_ext.py456 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/
H A Dcompileall.py88 from concurrent.futures.process import _check_system_limits
94 from concurrent.futures import ProcessPoolExecutor
/third_party/mesa3d/.gitlab-ci/bin/
H A Dci_run_n_monitor.py17 from concurrent.futures import ThreadPoolExecutor
/third_party/node/deps/v8/tools/
H A Dlocs.py24 from concurrent.futures import ThreadPoolExecutor
/third_party/nghttp2/src/
H A Dh2load.cc3136 std::vector<std::future<void>> futures; in main() local
3167 futures.push_back( in main()
3185 for (auto &fut : futures) { in main()

Completed in 27 milliseconds

12