/third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/Support/ |
H A D | ThreadPool.cpp | 84 auto Future = PackagedTask.get_future(); in asyncImpl() local 95 return Future.share(); in asyncImpl() 132 // Get a Future with launch::deferred execution using std::async 133 auto Future = std::async(std::launch::deferred, std::move(Task)).share(); 136 PackagedTaskTy PackagedTask([Future]() { Future.get(); }); 138 return Future;
|
/third_party/python/Lib/asyncio/ |
H A D | futures.py | 1 """A Future class similar to the one in PEP 3148.""" 4 'Future', 'wrap_future', 'isfuture', 30 class Future: class 31 """This class is *almost* compatible with concurrent.futures.Future. 61 # the Future protocol (i.e. is intended to be duck-type compatible). 66 # `await Future()` or`yield from Future()` (correct) vs. 67 # `yield Future()` (incorrect). 120 """Return the event loop the Future is bound to.""" 123 raise RuntimeError("Future objec [all...] |
H A D | __main__.py | 23 future = concurrent.futures.Future()
|
H A D | tasks.py | 79 # from a Python Future implementation. 81 """A coroutine wrapped in a Future.""" 86 # - or _fut_waiter is some Future, and _step() is *not* scheduled. 101 # raise after Future.__init__(), attrs are required for __del__ 196 Unlike Future.cancel, this does not guarantee that the 280 super().cancel() # I.e., Future.cancel(self). 289 # Yielded Future must come from Future.__iter__(). 292 f'Task {self!r} got Future ' 345 # as `Future [all...] |
H A D | windows_events.py | 48 class _OverlappedFuture(futures.Future): 49 """Subclass of Future which represents an overlapped operation. 96 class _BaseWaitHandleFuture(futures.Future): 97 """Subclass of Future which represents a wait handle.""" 171 """Subclass of Future which represents a wait for the cancellation of a 701 Return a Future object. The result of the future is True if the wait
|
H A D | base_events.py | 426 """Create a Future object attached to the loop.""" 427 return futures.Future(loop=self) 458 must return a Future. 618 """Run until the Future is done. 626 Return the Future's result, or raise its exception. 651 raise RuntimeError('Event loop stopped before Future completed.') 1780 - 'future' (optional): Future instance;
|
/third_party/python/Lib/concurrent/futures/ |
H A D | __init__.py | 15 Future, 27 'Future',
|
H A D | thread.py | 172 f = _base.Future()
|
H A D | _base.py | 50 """The Future was cancelled.""" 142 """A context manager that does an ordered acquire of Future conditions.""" 325 class Future(object): class 514 False if the Future was cancelled, True otherwise. 532 LOGGER.critical('Future %s in unexpected state: %s', 535 raise RuntimeError('Future in unexpected state') 576 a Future instance representing the execution of the callable. 579 A Future representing the given call.
|
H A D | process.py | 37 calls placed in the "Call Q" can no longer be cancelled with Future.cancel(). 105 # work while a larger number will make Future.cancel() succeed less frequently 777 f = _base.Future()
|
/third_party/python/Lib/test/ |
H A D | test_concurrent_futures.py | 27 PENDING, RUNNING, CANCELLED, CANCELLED_AND_NOTIFIED, FINISHED, Future, 43 f = Future() 790 futures_list = [Future() for _ in range(8)] 1383 f = Future() 1394 f = Future() 1405 f = Future() 1424 f = Future() 1438 f = Future() 1449 f = Future() 1460 f = Future() [all...] |
H A D | test_genericalias.py | 10 from concurrent.futures import Future namespace 124 Future, _WorkItem,
|
H A D | test_asyncgen.py | 1003 fut = asyncio.Future(loop=self.loop)
|
H A D | test_inspect.py | 255 class Future: class 258 self.assertTrue(inspect.isawaitable(Future())) 259 self.assertFalse(inspect.isawaitable(Future))
|
/third_party/python/Lib/test/test_asyncio/ |
H A D | test_tasks.py | 90 Future = None variable in BaseTaskTests 96 return self.__class__.Future(loop=loop) 159 r'Task .* got Future .* attached'): 685 # Test Future.result() after calling cancel() with a message. 719 # Test Future.exception() after calling cancel() with a message. 987 # When calling Future.result() on a cancelled task, check that the 1014 # When calling Future.exception() on a cancelled task, check that the 1069 'Event loop stopped before Future completed.') 1666 class Fut(asyncio.Future): 2445 BaseFuture = cls.Future 2462 class Future(CommonFuture, BaseFuture): global() class 2561 Future = getattr(futures, '_CFuture', None) global() variable in CTask_CFuture_Tests 2592 Future = getattr(futures, '_CFuture', None) global() variable in CTask_CFuture_SubclassTests 2601 Future = futures._PyFuture global() variable in CTaskSubclass_PyFuture_Tests 2609 Future = getattr(futures, '_CFuture', None) global() variable in PyTask_CFutureSubclass_Tests 2618 Future = futures._PyFuture global() variable in CTask_PyFuture_Tests 2626 Future = getattr(futures, '_CFuture', None) global() variable in PyTask_CFuture_Tests 2633 Future = futures._PyFuture global() variable in PyTask_PyFuture_Tests 2639 Future = futures._PyFuture global() variable in PyTask_PyFuture_SubclassTests [all...] |
H A D | test_ssl.py | 41 self.connected = asyncio.Future(loop=loop) 42 self.done = asyncio.Future(loop=loop) 226 fut = asyncio.Future() 1092 fut = asyncio.Future() 1498 self.fut = asyncio.Future(loop=loop) 1546 self.fut = asyncio.Future(loop=loop)
|
H A D | test_futures.py | 34 # Class that does not inherit from Future but aims to be duck-type 128 # As `isinstance(Mock(), Future)` returns `False` 135 # As `isinstance(Mock(Future), Future)` returns `True` 167 # Make sure Future doesn't accept a positional argument 171 # Test that C Future doesn't crash when Future.__init__() 272 # StopIteration cannot be raised into a Future - CPython issue26221 526 f1 = concurrent.futures.Future() 534 f1 = concurrent.futures.Future() [all...] |
H A D | test_streams.py | 948 stream._waiter = asyncio.Future(loop=self.loop) 951 r"<StreamReader waiter=<Future pending[\S ]*>>")
|
/third_party/python/Lib/unittest/test/testmock/ |
H A D | testasync.py | 200 self.assertIsInstance(mock, asyncio.Future) 476 fut = asyncio.Future() 480 self.assertIsInstance(result, asyncio.Future) 483 fut = asyncio.Future() 488 self.assertIsInstance(result, asyncio.Future) 501 value = asyncio.Future()
|
/third_party/rust/crates/either/src/ |
H A D | lib.rs | 29 use core::future::Future; 1073 impl<L, R> Future for Either<L, R> 1075 L: Future, 1076 R: Future<Output = L::Output>,
|
/third_party/rust/crates/memchr/bench/data/code/ |
H A D | rust-library.rs | 23155 /// use std::future::Future; 23170 /// fn block_on<T>(fut: impl Future<Output = T>) -> T { [all...] |