- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 490 for wait (0.04 seconds)
-
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) -
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) -
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) -
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) -
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) -
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 * JVMCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 45.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/ds/AbstractDataStoreTest.java
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) -
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) -
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) -
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)