Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 507 for await (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. docs/em/docs/tutorial/background-tasks.md

    ## ✍ 📋 🔢
    
    ✍ 🔢 🏃 🖥 📋.
    
    ⚫️ 🐩 🔢 👈 💪 📨 🔢.
    
    ⚫️ 💪 `async def` ⚖️ 😐 `def` 🔢, **FastAPI** 🔜 💭 ❔ 🍵 ⚫️ ☑.
    
    👉 💼, 📋 🔢 🔜 ✍ 📁 (⚖ 📨 📧).
    
    & ✍ 🛠️ 🚫 ⚙️ `async` & `await`, 👥 🔬 🔢 ⏮️ 😐 `def`:
    
    {* ../../docs_src/background_tasks/tutorial001.py hl[6:9] *}
    
    ## 🚮 🖥 📋
    
    🔘 👆 *➡ 🛠️ 🔢*, 🚶‍♀️ 👆 📋 🔢 *🖥 📋* 🎚 ⏮️ 👩‍🔬 `.add_task()`:
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top