Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 567 for future (0.03 sec)

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

        }
    
        @Override
        public <T> Future<T> submit(Callable<T> task) {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public Future<?> submit(Runnable task) {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public <T> Future<T> submit(Runnable task, T result) {
          throw new UnsupportedOperationException();
        }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

      static <V extends @Nullable Object, X extends Exception> V getChecked(
          Future<V> future, Class<X> exceptionClass) throws X {
        return getChecked(bestGetCheckedTypeValidator(), future, exceptionClass);
      }
    
      /** Implementation of {@link Futures#getChecked(Future, Class)}. */
      @CanIgnoreReturnValue
      @VisibleForTesting
      @ParametricNullness
      static <V extends @Nullable Object, X extends Exception> V getChecked(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java

        checkNotNull(timeoutUnit);
        checkPositiveTimeout(timeoutDuration);
    
        Future<T> future = executor.submit(callable);
    
        try {
          return amInterruptible
              ? future.get(timeoutDuration, timeoutUnit)
              : getUninterruptibly(future, timeoutDuration, timeoutUnit);
        } catch (InterruptedException e) {
          future.cancel(true);
          throw e;
        } catch (ExecutionException e) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  4. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

            return new ExecutionListWrapper() {
              final AbstractFuture<?> future = new AbstractFuture<Object>() {};
    
              @Override
              public void add(Runnable runnable, Executor executor) {
                future.addListener(runnable, executor);
              }
    
              @Override
              public void execute() {
                future.set(null);
              }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

            if (future.listenersField == expect) {
              future.listenersField = update;
              return true;
            }
            return false;
          }
        }
    
        @Override
        @Nullable Listener gasListeners(AbstractFutureState<?> future, Listener update) {
          synchronized (future) {
            Listener old = future.listenersField;
            if (old != update) {
              future.listenersField = update;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

            if (future.listenersField == expect) {
              future.listenersField = update;
              return true;
            }
            return false;
          }
        }
    
        @Override
        @Nullable Listener gasListeners(AbstractFutureState<?> future, Listener update) {
          synchronized (future) {
            Listener old = future.listenersField;
            if (old != update) {
              future.listenersField = update;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  7. android/guava-tests/benchmark/com/google/common/util/concurrent/FuturesGetCheckedBenchmark.java

        }
      }
    
      private enum Result {
        SUCCESS(immediateFuture(new Object())),
        FAILURE(immediateFailedFuture(new Exception()));
    
        final Future<Object> future;
    
        Result(Future<Object> result) {
          this.future = result;
        }
      }
    
      private enum ExceptionType {
        CHECKED(IOException.class),
        UNCHECKED(RuntimeException.class);
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java

              }
    
              @Override
              public void onFailure(Throwable t) {
                failureCalls[0]++;
              }
            };
        addCallback(future, callback, directExecutor());
        future.set(result);
        assertEquals(result, future.get());
        assertThat(successCalls[0]).isEqualTo(1);
        assertThat(failureCalls[0]).isEqualTo(0);
      }
    
      public void testOnSuccessThrowsError() throws Exception {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/AsyncCallable.java

     * result.
     *
     * @since 20.0
     */
    @FunctionalInterface
    @GwtCompatible
    public interface AsyncCallable<V extends @Nullable Object> {
      /**
       * Computes a result {@code Future}. The output {@code Future} need not be {@linkplain
       * Future#isDone done}, making {@code AsyncCallable} suitable for asynchronous derivations.
       *
       * <p>Throwing an exception from this method is equivalent to returning a failing {@link
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        SettableFuture<Integer> future = SettableFuture.create();
        assertTrue(future.set(42));
        // Later attempts to set the future should return false.
        assertFalse(future.set(23));
        assertFalse(future.setException(new Exception("bar")));
        assertFalse(future.setFuture(SettableFuture.<Integer>create()));
        // Check that the future has been set properly.
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 7.3K bytes
    - Viewed (0)
Back to top