Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 68 for finisher (0.06 seconds)

  1. 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 {@link
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  2. 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 {@link
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  3. 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)
  4. docs/en/docs/advanced/events.md

    Because this code is executed before the application **starts** taking requests, and right after it **finishes** handling requests, it covers the whole application **lifespan** (the word "lifespan" will be important in a second 😉).
    
    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)
  5. 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
       */
      @J2ktIncompatible
    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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top