Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 490 for wait (0.04 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

            executor.execute(wrapper);
          }
          barrier.await(); // release the threads!
          barrier.await(); // wait for them all to complete
          assertEquals(1, task.get().intValue());
          assertEquals(1, counter.get());
        }
        executor.shutdown();
      }
    
      @J2ktIncompatible
      @GwtIncompatible // blocking wait
      public void testToString() throws Exception {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 6.5K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

            executor.execute(wrapper);
          }
          barrier.await(); // release the threads!
          barrier.await(); // wait for them all to complete
          assertEquals(1, task.get().intValue());
          assertEquals(1, counter.get());
        }
        executor.shutdown();
      }
    
      @J2ktIncompatible
      @GwtIncompatible // blocking wait
      public void testToString() throws Exception {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 6.5K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

        /*
         * An uninterruptible wait on a Condition requires different logic than an uninterruptible wait
         * on most other types: In cases in which we "should" receive both an interrupt and a
         * notification nearly simultaneously, we sometimes receive only an interrupt. Thus, when we're
         * interrupted, we can't just poll whether it's time to end the wait because our "end the wait"
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 23:24:32 GMT 2026
    - 22.5K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        // the run latch.
        exec.execute(task);
        runLatch.await();
        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
        // Finish the task by unblocking the task latch.  Then wait for the
        // listener to be called by blocking on the listener latch.
        taskLatch.countDown();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/Monitor.java

        if (!((guard.monitor == this) && lock.isHeldByCurrentThread())) {
          throw new IllegalMonitorStateException();
        }
        if (!guard.isSatisfied()) {
          await(guard, true);
        }
      }
    
      /**
       * Waits for the guard to be satisfied. Waits at most the given time, and may be interrupted. May
       * be called only by a thread currently occupying this monitor.
       *
       * @return whether the guard is now satisfied
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 43.5K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * is complete. It does so by using daemon threads and adding a shutdown hook to wait for their
       * completion.
       *
       * <p>This is mainly for fixed thread pools. See {@link Executors#newFixedThreadPool(int)}.
       *
       * @param executor the executor to modify to make sure it exits when the application is finished
       * @param terminationTimeout how long to wait for the executor to finish before terminating the
       *     JVM
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 45.6K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/ds/AbstractDataStoreTest.java

            Thread.sleep(50);
    
            // Release all threads to start simultaneously
            startLatch.countDown();
    
            // Wait for writer thread to complete
            writerThread.join(1000);
    
            // Wait for all reader threads to complete
            for (Thread thread : readerThreads) {
                thread.join(testDurationMs + 1000);
            }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 12.8K bytes
    - Click Count (1)
  8. src/test/java/org/codelibs/fess/helper/ProcessHelperTest.java

                assertTrue(processHelper.isProcessRunning());
    
                // Wait a bit for the processes to start
                Thread.sleep(50);
    
                // Destroy all processes
                processHelper.destroy();
    
                // Wait a bit for destruction to complete
                Thread.sleep(100);
    
                assertFalse(processHelper.isProcessRunning());
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 16K bytes
    - Click Count (0)
  9. docs/en/docs/async.md

    ```Python
    burgers = await get_burgers(2)
    ```
    
    The key here is the `await`. It tells Python that it has to wait ⏸ for `get_burgers(2)` to finish doing its thing 🕙 before storing the results in `burgers`. With that, Python will know that it can go and do something else 🔀 ⏯ in the meanwhile (like receiving another request).
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 23.4K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        // the run latch.
        exec.execute(task);
        runLatch.await();
        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
        // Finish the task by unblocking the task latch.  Then wait for the
        // listener to be called by blocking on the listener latch.
        taskLatch.countDown();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4.7K bytes
    - Click Count (0)
Back to Top