- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for invokeAny (0.05 sec)
-
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)
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:37:28 UTC 2025 - 6.5K bytes - Viewed (0) -
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)
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:37:28 UTC 2025 - 6.5K bytes - Viewed (0) -
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)
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 5.4K bytes - Viewed (0) -
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)
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 4.1K bytes - Viewed (0) -
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
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 6.6K bytes - Viewed (0) -
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
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 6.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListeningExecutorService.java
} /** * Duration-based overload of {@link #invokeAny(Collection, long, TimeUnit)}. * * @since 32.1.0 */ @J2ktIncompatible default <T extends @Nullable Object> T invokeAny( Collection<? extends Callable<T>> tasks, Duration timeout) throws InterruptedException, ExecutionException, TimeoutException { return invokeAny(tasks, toNanosSaturated(timeout), TimeUnit.NANOSECONDS); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 5.5K bytes - Viewed (0) -
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)
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 7.4K bytes - Viewed (0)