- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 507 for await (0.15 sec)
-
src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java
} /** * Returns the response. * @param time The time to wait. * @param unit The time unit. * @return The response. */ public RESPONSE getResponse(final long time, final TimeUnit unit) { try { final boolean isTimeout = !latch.await(time, unit); if (isTimeout) {
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Fri Jul 04 14:00:23 UTC 2025 - 7.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
// (which will block) in the same thread. new Thread() { @Override public void run() { inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA); } }.start(); funcIsWaitingLatch.await(); assertTrue(resultFuture.cancel(true)); assertTrue(resultFuture.isCancelled()); assertFalse(inputFuture.isCancelled()); assertFalse(outputFuture.isCancelled());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 6.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
// (which will block) in the same thread. new Thread() { @Override public void run() { inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA); } }.start(); funcIsWaitingLatch.await(); assertTrue(resultFuture.cancel(true)); assertTrue(resultFuture.isCancelled()); assertFalse(inputFuture.isCancelled()); assertFalse(outputFuture.isCancelled());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 6.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
lock.lock(); try { locked.countDown(); finishLatch.await(1, MINUTES); } catch (InterruptedException e) { fail(e.toString()); } finally { lock.unlock(); } } void waitUntilHoldingLock() throws InterruptedException { locked.await(1, MINUTES); } void releaseLockAndFinish() throws InterruptedException {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 16.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
lock.lock(); try { locked.countDown(); finishLatch.await(1, MINUTES); } catch (InterruptedException e) { fail(e.toString()); } finally { lock.unlock(); } } void waitUntilHoldingLock() throws InterruptedException { locked.await(1, MINUTES); } void releaseLockAndFinish() throws InterruptedException {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 16.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
*/ @GuardedBy("lock") private void await(Guard guard, boolean signalBeforeWaiting) throws InterruptedException { if (signalBeforeWaiting) { signalNextWaiter(); } beginWaitingFor(guard); try { do { guard.condition.await(); } while (!guard.isSatisfied()); } finally { endWaitingFor(guard); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 42.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
val entryTime = System.nanoTime() for (queue in TaskRunner.INSTANCE.activeQueues()) { // We wait at most 1 second, so we don't ever turn multiple lost threads into // a test timeout failure. val waitTime = (entryTime + 1_000_000_000L - System.nanoTime()) if (!queue.idleLatch().await(waitTime, TimeUnit.NANOSECONDS)) { TaskRunner.INSTANCE.withLock { TaskRunner.INSTANCE.cancelAll()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 10.5K bytes - Viewed (0) -
docs/em/docs/tutorial/background-tasks.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Nov 18 02:25:44 UTC 2024 - 3.7K bytes - Viewed (0) -
docs/uk/docs/index.md
return {"item_id": item_id, "q": q} ``` <details markdown="1"> <summary>Або використайте <code>async def</code>...</summary> Якщо ваш код використовує `async` / `await`, скористайтеся `async def`: ```Python hl_lines="9 14" from typing import Union from fastapi import FastAPI app = FastAPI() @app.get("/") async def read_root():
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 10:49:48 UTC 2025 - 24.2K bytes - Viewed (0) -
docs/uk/docs/tutorial/testing.md
{* ../../docs_src/app_testing/tutorial001.py hl[2,12,15:18] *} /// tip | Порада Зверніть увагу, що тестові функції — це звичайні `def`, а не `async def`. Виклики клієнта також звичайні, без використання `await`. Це дозволяє використовувати `pytest` без зайвих ускладнень. /// /// note | Технічні деталі Ви також можете використовувати `from starlette.testclient import TestClient`.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Fri Feb 28 14:12:19 UTC 2025 - 9.5K bytes - Viewed (0)