Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 354 for Futures (0.04 seconds)

  1. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

     * result. (If you want such access, you may prefer {@link Futures#addCallback
     * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful:
     *
     * {@snippet :
     * final String name = ...;
     * inFlight.add(name);
     * ListenableFuture<Result> future = service.query(name);
     * future.addListener(new Runnable() {
     *   public void run() {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  2. guava/src/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java

    import com.google.common.annotations.J2ktIncompatible;
    
    /**
     * Hidden superclass of {@link Futures} that provides us a place to declare special GWT versions of
     * the {@link Futures#catching(ListenableFuture, Class, com.google.common.base.Function,
     * java.util.concurrent.Executor) Futures.catching} family of methods. Those versions have slightly
     * different signatures.
     */
    @GwtCompatible
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 1.4K bytes
    - Click Count (0)
  3. android/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(
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  4. guava/src/com/google/common/util/concurrent/CollectionFuture.java

      CollectionFuture(
          ImmutableCollection<? extends ListenableFuture<? extends V>> futures,
          boolean allMustSucceed) {
        super(futures, allMustSucceed, true);
    
        List<@Nullable Present<V>> values =
            futures.isEmpty()
                ? Collections.<@Nullable Present<V>>emptyList()
                : Lists.<@Nullable Present<V>>newArrayListWithCapacity(futures.size());
    
        // Populate the results list with null initially.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  5. 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);
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

          List<Future<String>> futures = testExecutor.invokeAll(tasks);
          mock.assertLastMethodCalled("invokeAll");
          checkResults(futures);
        }
        {
          MockExecutor mock = new MockExecutor();
          TimeUnit unit = SECONDS;
          long timeout = 5;
          TestExecutor testExecutor = new TestExecutor(mock);
          List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Jul 14 14:44:08 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetDoneTest.java

    import static com.google.common.util.concurrent.Futures.getDone;
    import static com.google.common.util.concurrent.Futures.immediateCancelledFuture;
    import static com.google.common.util.concurrent.Futures.immediateFailedFuture;
    import static com.google.common.util.concurrent.Futures.immediateFuture;
    import static com.google.common.util.concurrent.Futures.immediateVoidFuture;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  8. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java

    import java.util.concurrent.Executor;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Hidden superclass of {@link Futures} that provides us a place to declare special GWT versions of
     * the {@link Futures#catching(ListenableFuture, Class, com.google.common.base.Function)
     * Futures.catching} family of methods. Those versions have slightly different signatures.
     */
    abstract class GwtFuturesCatchingSpecialization {
      /*
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 2K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        private final ListenableFuture<@Nullable Void> future;
        private boolean called = false;
    
        private TestCallable(ListenableFuture<@Nullable Void> future) {
          this.future = future;
        }
    
        @Override
        public ListenableFuture<@Nullable Void> call() throws Exception {
          called = true;
          return future;
        }
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java

        try {
          List<Future<int[]>> futures = newArrayListWithExpectedSize(nTasks);
          for (int i = 0; i < nTasks; i++) {
            futures.add(pool.submit(new MutateTask(multiset, keys)));
          }
    
          int[] deltas = new int[3];
          for (Future<int[]> future : futures) {
            int[] taskDeltas = future.get();
            for (int i = 0; i < deltas.length; i++) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Dec 08 22:42:14 GMT 2025
    - 5.7K bytes
    - Click Count (0)
Back to Top