Home
last modified time | relevance | path

Searched refs:future (Results 1 - 25 of 88) sorted by relevance

1234

/third_party/python/Lib/asyncio/
H A Dbase_futures.py45 def _future_repr_info(future):
48 info = [future._state.lower()]
49 if future._state == _FINISHED:
50 if future._exception is not None:
51 info.append(f'exception={future._exception!r}')
55 result = reprlib.repr(future._result)
57 if future._callbacks:
58 info.append(_format_callbacks(future._callbacks))
59 if future._source_traceback:
60 frame = future
[all...]
H A D__main__.py23 future = concurrent.futures.Future()
39 future.set_exception(ex)
42 future.set_exception(ex)
46 future.set_result(coro)
51 futures._chain_future(repl_future, future)
53 future.set_exception(exc)
58 return future.result()
H A Dfutures.py38 raise an exception when the future isn't done yet.
73 """Initialize the future.
76 loop object used by the future. If it's not provided, the future uses
101 'future': self,
147 """Cancel the future and schedule callbacks.
149 If the future is already done or cancelled, return False. Otherwise,
150 change the future's state to cancelled, schedule the callbacks and
176 """Return True if the future was cancelled."""
182 """Return True if the future i
[all...]
H A Dtasks.py337 def __wakeup(self, future):
339 future.result()
344 # Don't pass the value of `future.result()` explicitly,
464 # wait until the future completes or the timeout
542 """Cancel the *fut* future or task and wait until it completes."""
634 future = loop.create_future()
637 future, result)
639 return await future
645 """Wrap a coroutine or an awaitable in a future.
655 raise ValueError('The future belong
[all...]
H A Dbase_events.py6 immediately or at a given time in the future.
266 # Cancel the future.
569 future = self.create_future()
570 thread = threading.Thread(target=self._do_shutdown, args=(future,))
573 await future
577 def _do_shutdown(self, future):
581 self.call_soon_threadsafe(future.set_result, None)
584 self.call_soon_threadsafe(future.set_exception, ex)
617 def run_until_complete(self, future):
631 new_task = not futures.isfuture(future)
[all...]
/third_party/python/Lib/concurrent/futures/
H A D_base.py17 # Possible future states (for internal use by the futures package).
20 # The future was cancelled by the user...
46 """Base class for all future-related exceptions."""
65 def add_result(self, future):
66 self.finished_futures.append(future)
68 def add_exception(self, future):
69 self.finished_futures.append(future)
71 def add_cancelled(self, future):
72 self.finished_futures.append(future)
81 def add_result(self, future)
[all...]
H A Dthread.py47 def __init__(self, future, fn, args, kwargs):
48 self.future = future
54 if not self.future.set_running_or_notify_cancel():
60 self.future.set_exception(exc)
64 self.future.set_result(result)
214 work_item.future.set_exception(BrokenThreadPool(self._broken))
228 work_item.future.cancel()
H A Dprocess.py23 | | | future | | | | 4, result | | |
38 - reads _ResultItems from "Result Q", updates the future stored in the
140 def __init__(self, future, fn, args, kwargs):
141 self.future = future
162 """Safe Queue set exception to the future object linked to a job"""
181 work_item.future.set_exception(e)
391 if work_item.future.set_running_or_notify_cancel():
446 # Received a _ResultItem so mark the future as completed.
451 work_item.future
[all...]
/third_party/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/duration/
H A DPeriod.java18 * or future, and as being more or less than the defined value.
124 * Mark the time as being in the future.
142 * Mark the duration as extending into the future if
143 * future is true, and into the past otherwise.
145 * @param future true if the time is in the future
148 public Period inFuture(boolean future) { in inFuture() argument
149 return setFuture(future); in inFuture()
154 * past is true, and into the future otherwise.
201 * duration into the future
295 Period(int limit, boolean future, float count, TimeUnit unit) Period() argument
347 setFuture(boolean future) setFuture() argument
[all...]
/third_party/icu/ohos_icu4j/src/main/java/ohos/global/icu/impl/duration/
H A DPeriod.java19 * or future, and as being more or less than the defined value.
126 * Mark the time as being in the future.
144 * Mark the duration as extending into the future if
145 * future is true, and into the past otherwise.
147 * @param future true if the time is in the future
150 public Period inFuture(boolean future) { in inFuture() argument
151 return setFuture(future); in inFuture()
156 * past is true, and into the future otherwise.
203 * duration into the future
297 Period(int limit, boolean future, float count, TimeUnit unit) Period() argument
349 setFuture(boolean future) setFuture() argument
[all...]
/third_party/skia/third_party/externals/angle2/src/libANGLE/
H A DWorkerThread.cpp17 # include <future>
91 void setFuture(std::future<void> &&future);
100 std::future<void> mFuture;
103 void AsyncWaitableEvent::setFuture(std::future<void> &&future) in setFuture() argument
105 mFuture = std::move(future); in setFuture()
191 auto future = std::async(std::launch::async, [closure, this] { in checkToRunPendingTasks() local
209 waitable->setFuture(std::move(future)); in checkToRunPendingTasks()
/third_party/node/deps/openssl/openssl/crypto/sha/asm/
H A Dsha1-armv8.pl78 add $d,$d,$K // future e+=K
82 add $d,$d,@Xw[($i+1)&15] // future e+=X[i]
95 add $d,$d,$K // future e+=K
100 add $d,$d,@Xw[($i+1)&15] // future e+=X[i]
120 add $d,$d,$K // future e+=K
126 add $d,$d,@Xw[($i+1)&15] // future e+=X[i]
144 add $d,$d,$K // future e+=K
150 add $d,$d,@Xw[($i+1)&15] // future e+=X[i]
158 add $d,$d,$K // future e+=K
162 add $d,$d,@Xw[($i+1)&15] // future
[all...]
/third_party/openssl/crypto/sha/asm/
H A Dsha1-armv8.pl78 add $d,$d,$K // future e+=K
82 add $d,$d,@Xw[($i+1)&15] // future e+=X[i]
95 add $d,$d,$K // future e+=K
100 add $d,$d,@Xw[($i+1)&15] // future e+=X[i]
120 add $d,$d,$K // future e+=K
126 add $d,$d,@Xw[($i+1)&15] // future e+=X[i]
144 add $d,$d,$K // future e+=K
150 add $d,$d,@Xw[($i+1)&15] // future e+=X[i]
158 add $d,$d,$K // future e+=K
162 add $d,$d,@Xw[($i+1)&15] // future
[all...]
/third_party/python/Lib/test/
H A Dtest_concurrent_futures.py253 future = self.executor.submit(get_init_status)
259 future.result()
401 """shutdown(wait=True) doesn't hang when a future was submitted and
610 future = self.executor.submit(time.sleep, 1.5)
611 done, not_done = futures.wait([future, future],
613 self.assertEqual({future}, done)
762 for future in futures.as_completed(
768 completed_futures.add(future)
795 for future i
[all...]
/third_party/mesa3d/src/util/
H A Dcnd_monotonic.h117 const uint64_t future = (abs_time->tv_sec * 1000) + (abs_time->tv_nsec / 1000000); in u_cnd_monotonic_timedwait() local
119 const DWORD timeout = (future > now) ? (DWORD)(future - now) : 0; in u_cnd_monotonic_timedwait()
/third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/
H A DTaskQueue.h25 #include <future>
77 /// Asynchronous submission of a task to the queue. The returned future can be
81 std::future<typename std::result_of<Callable()>::type> async(Callable &&C) { in async()
88 std::future<ResultTy> F = T.P->get_future(); in async()
/third_party/vk-gl-cts/external/vulkancts/vkscserver/
H A DvksIPC.cpp25 #include <future>
113 vector<std::future<void>> clients; in ParentLoop()
126 remove_erase_if(clients, [](const std::future<void>& c) { return is_ready(c); }); in ParentLoop()
169 std::future<void> CreateClientThread (ChildConnection client) in CreateClientThread()
H A Dserver.cpp27 #include <future>
92 std::future<void> CreateClientThread (Client client);
120 vector<std::future<void>> clients; in main()
127 remove_erase_if(clients, [](const std::future<void>& c) { return is_ready(c); }); in main()
261 std::future<void> CreateClientThread (Client client) in CreateClientThread()
H A DvksCommon.hpp30 #include <future>
49 bool is_ready (const std::future<R>& f) in is_ready()
/third_party/python/Lib/test/test_asyncio/
H A Dtest_futures2.py19 future = self.cls(raise_exc())
23 await future
26 self.assertEqual(tb.count("await future"), 1)
/third_party/rust/crates/regex/examples/
H A Dshootout-regex-dna.rs42 let future = thread::spawn(move || variant.find_iter(&seq).count()); in main()
43 counts.push((restr, future)); in main()
H A Dshootout-regex-dna-bytes.rs42 let future = thread::spawn(move || variant.find_iter(&seq).count()); in main()
43 counts.push((restr, future)); in main()
/third_party/skia/third_party/externals/oboe/samples/RhythmGame/src/main/cpp/
H A DGame.h20 #include <future>
74 std::future<void> mLoadingResult;
/third_party/node/deps/openssl/config/archs/linux-armv4/asm/crypto/sha/
H A Dsha256-armv4.S178 ldr r2,[sp,#2*4] @ from future BODY_16_xx
180 ldr r1,[sp,#15*4] @ from future BODY_16_xx
236 ldr r2,[sp,#3*4] @ from future BODY_16_xx
238 ldr r1,[sp,#0*4] @ from future BODY_16_xx
294 ldr r2,[sp,#4*4] @ from future BODY_16_xx
296 ldr r1,[sp,#1*4] @ from future BODY_16_xx
352 ldr r2,[sp,#5*4] @ from future BODY_16_xx
354 ldr r1,[sp,#2*4] @ from future BODY_16_xx
410 ldr r2,[sp,#6*4] @ from future BODY_16_xx
412 ldr r1,[sp,#3*4] @ from future BODY_16_x
[all...]
/third_party/node/deps/openssl/config/archs/linux-armv4/asm_avx2/crypto/sha/
H A Dsha256-armv4.S178 ldr r2,[sp,#2*4] @ from future BODY_16_xx
180 ldr r1,[sp,#15*4] @ from future BODY_16_xx
236 ldr r2,[sp,#3*4] @ from future BODY_16_xx
238 ldr r1,[sp,#0*4] @ from future BODY_16_xx
294 ldr r2,[sp,#4*4] @ from future BODY_16_xx
296 ldr r1,[sp,#1*4] @ from future BODY_16_xx
352 ldr r2,[sp,#5*4] @ from future BODY_16_xx
354 ldr r1,[sp,#2*4] @ from future BODY_16_xx
410 ldr r2,[sp,#6*4] @ from future BODY_16_xx
412 ldr r1,[sp,#3*4] @ from future BODY_16_x
[all...]

Completed in 12 milliseconds

1234