Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 9 of 9 for invokeAny (0.28 seconds)

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

        return delegate().invokeAll(tasks, timeout, unit);
      }
    
      @Override
      public <T extends @Nullable Object> T invokeAny(Collection<? extends Callable<T>> tasks)
          throws InterruptedException, ExecutionException {
        return delegate().invokeAny(tasks);
      }
    
      @Override
      public <T extends @Nullable Object> T invokeAny(
          Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.1K bytes
    - Click Count (0)
  2. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * submitted tasks and to collections of tasks submitted via {@code invokeAll}, {@code invokeAny},
       * {@code schedule}, {@code scheduleAtFixedRate}, and {@code scheduleWithFixedDelay}. In the case
       * of tasks submitted by {@code invokeAll} or {@code invokeAny}, tasks will run serially on the
       * calling thread. Tasks are run to completion before a {@code Future} is returned to the caller
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  3. guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * submitted tasks and to collections of tasks submitted via {@code invokeAll}, {@code invokeAny},
       * {@code schedule}, {@code scheduleAtFixedRate}, and {@code scheduleWithFixedDelay}. In the case
       * of tasks submitted by {@code invokeAll} or {@code invokeAny}, tasks will run serially on the
       * calling thread. Tasks are run to completion before a {@code Future} is returned to the caller
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java

      public void testInvokeAny() throws Exception {
        Set<Callable<String>> tasks = Collections.singleton(() -> "invokeAny");
    
        String result = executorService.invokeAny(tasks, Duration.ofSeconds(7));
    
        assertThat(result).isEqualTo("invokeAny");
        assertThat(recordedTasks).isSameInstanceAs(tasks);
        assertThat(recordedTimeUnit).isEqualTo(NANOSECONDS);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 4.6K bytes
    - Click Count (0)
  5. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        return delegate.invokeAll(tasks, timeout, unit);
      }
    
      @Override
      public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
          throws InterruptedException, ExecutionException {
        Preconditions.checkNotNull(tasks, "tasks must not be null!");
        return delegate.invokeAny(tasks);
      }
    
      @Override
      public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:37:28 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  6. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        return delegate.invokeAll(tasks, timeout, unit);
      }
    
      @Override
      public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
          throws InterruptedException, ExecutionException {
        Preconditions.checkNotNull(tasks, "tasks must not be null!");
        return delegate.invokeAny(tasks);
      }
    
      @Override
      public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:37:28 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java

      }
    
      @Override
      public final <T extends @Nullable Object> T invokeAny(Collection<? extends Callable<T>> tasks)
          throws InterruptedException, ExecutionException {
        return delegate.invokeAny(wrapTasks(tasks));
      }
    
      @Override
      public final <T extends @Nullable Object> T invokeAny(
          Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

          throw new UnsupportedOperationException();
        }
    
        @Override
        public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
            throws ExecutionException, InterruptedException {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.5K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

          throw new UnsupportedOperationException();
        }
    
        @Override
        public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
            throws ExecutionException, InterruptedException {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.5K bytes
    - Click Count (0)
Back to Top