Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 728 for futures (0.04 sec)

  1. android/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);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  2. 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(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  3. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  4. fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java

            // Execute callable tasks concurrently
            final ExecutorService executor = Executors.newFixedThreadPool(numTasks);
            try {
                final List<Future<Integer>> futures = executor.invokeAll(tasks);
                for (final Future<Integer> future : futures) {
                    future.get();
                }
            } catch (final InterruptedException e) {
                // Interrupted while waiting
            } catch (final ExecutionException e) {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  5. 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
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 1.4K bytes
    - Viewed (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);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 9.9K 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  8. 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;
        }
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  9. 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;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  10. 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 {
      /*
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2K bytes
    - Viewed (0)
Back to top