- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 68 for finisher (0.06 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
final ListenableFuture<String> future; final String name; final Runnable finisher; TestFuture(ListenableFuture<String> future, String name, Runnable finisher) { this.future = future; this.name = name; this.finisher = finisher; } } /** * A collection of several futures, covering cancellation, success, and failure (both {@linkCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 134K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
final ListenableFuture<String> future; final String name; final Runnable finisher; TestFuture(ListenableFuture<String> future, String name, Runnable finisher) { this.future = future; this.name = name; this.finisher = finisher; } } /** * A collection of several futures, covering cancellation, success, and failure (both {@linkCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 134K bytes - Click Count (0) -
docs/en/docs/async.md
Then you go to the counter 🔀, to the initial task that is now finished ⏯, pick the burgers, say thanks and take them to the table. That finishes that step / task of interaction with the counter ⏹. That in turn, creates a new task, of "eating burgers" 🔀 ⏯, but the previous one of "getting burgers" is finished ⏹. ### Parallel Burgers { #parallel-burgers } Now let's imagine these aren't "Concurrent Burgers", but "Parallel Burgers".
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) -
docs/en/docs/advanced/events.md
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 7.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* * <p>This method waits 120 seconds before continuing with JVM termination, even if the executor * has not finished its work. * * <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 * @return an unmodifiable version of the input which will not hang the JVM */ @J2ktIncompatibleCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 45.6K bytes - Click Count (0) -
docs/en/docs/advanced/advanced-dependencies.md
In version 0.121.0, FastAPI added support for `Depends(scope="function")` for dependencies with `yield`. Using `Depends(scope="function")`, the exit code after `yield` is executed right after the *path operation function* is finished, before the response is sent back to the client. And when using `Depends(scope="request")` (the default), the exit code after `yield` is executed after the response is sent.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 9K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt
"FINE: Q10000 starting : task", "FINE: Q10000 finished run in 0 µs: task", "FINE: Q10000 run again after 50 µs: task", "FINE: Q10000 starting : task", "FINE: Q10000 finished run in 0 µs: task", "FINE: Q10000 run again after 150 µs: task", "FINE: Q10000 starting : task", "FINE: Q10000 finished run in 0 µs: task", ) }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 22:17:59 GMT 2026 - 23K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
assertFalse(singleCallListener.wasCalled()); assertTrue(listenableFuture.isDone()); // We call AbstractFuture#set above. // #addListener() will run the listener immediately because the Future is // already finished (we explicitly set the result of it above). listenableFuture.addListener(singleCallListener, directExecutor()); assertThat(listenableFuture.get()).isEqualTo(DATA1);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 10K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
assertFalse(singleCallListener.wasCalled()); assertTrue(listenableFuture.isDone()); // We call AbstractFuture#set above. // #addListener() will run the listener immediately because the Future is // already finished (we explicitly set the result of it above). listenableFuture.addListener(singleCallListener, directExecutor()); assertThat(listenableFuture.get()).isEqualTo(DATA1);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 10K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
assertThat(stopwatch.elapsed(MILLISECONDS)).isIn(Range.closed(NOT_ENOUGH_MS, DELAY_MS * 2)); // Is it still computing away anyway? assertThat(target.finished).isFalse(); MILLISECONDS.sleep(ENOUGH_MS); assertThat(target.finished).isFalse(); } public void testNewProxy_badMethodWithEnoughTime() throws Exception { SampleImpl target = new SampleImpl(DELAY_MS);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 9.4K bytes - Click Count (0)