Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for withTimeout (0.04 sec)

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

        assertThat(f.get()).isEqualTo(2);
      }
    
      @J2ktIncompatible
      @GwtIncompatible // withTimeout
      public void testWithTimeout() throws Exception {
        ScheduledExecutorService executor = newScheduledThreadPool(1);
        try {
          FluentFuture<?> f =
              FluentFuture.from(SettableFuture.create()).withTimeout(0, SECONDS, executor);
          ExecutionException e = assertThrows(ExecutionException.class, () -> f.get());
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 17:50:58 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

      @GwtIncompatible // ScheduledExecutorService
      @IgnoreJRERequirement // Users will use this only if they're already using Duration.
      public final FluentFuture<V> withTimeout(
          Duration timeout, ScheduledExecutorService scheduledExecutor) {
        return withTimeout(toNanosSaturated(timeout), TimeUnit.NANOSECONDS, scheduledExecutor);
      }
    
      /**
       * Returns a future that delegates to this future but will finish early (via a {@link
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/Futures.java

      @IgnoreJRERequirement // Users will use this only if they're already using Duration.
      public static <V extends @Nullable Object> ListenableFuture<V> withTimeout(
          ListenableFuture<V> delegate, Duration time, ScheduledExecutorService scheduledExecutor) {
        return withTimeout(delegate, toNanosSaturated(time), TimeUnit.NANOSECONDS, scheduledExecutor);
      }
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for
     *       example, if the deadline expires on a {@code Future} returned from {@link
     *       Futures#withTimeout} while the {@code Future} it wraps continues its underlying work. So
     *       beware: <i>Your {@code AsyncCallable} should not complete its {@code Future} until it is
     *       safe for the next task to start.</i>
     * </ul>
     *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for
     *       example, if the deadline expires on a {@code Future} returned from {@link
     *       Futures#withTimeout} while the {@code Future} it wraps continues its underlying work. So
     *       beware: <i>Your {@code AsyncCallable} should not complete its {@code Future} until it is
     *       safe for the next task to start.</i>
     * </ul>
     *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
Back to top