- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 3,266 for pollable (0.13 sec)
-
guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
} @Override public <T extends @Nullable Object> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks) throws InterruptedException { return delegate().invokeAll(tasks); } @Override public <T extends @Nullable Object> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 4.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java
@Override @ParametricNullness public <T extends @Nullable Object> T callWithTimeout( Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit) throws ExecutionException { checkNotNull(callable); checkNotNull(timeoutUnit); try { return callable.call(); } catch (RuntimeException e) { throw new UncheckedExecutionException(e);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 3.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java
} @ParametricNullness private <T extends @Nullable Object> T callWithTimeout( Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit, boolean amInterruptible) throws Exception { checkNotNull(callable); checkNotNull(timeoutUnit); checkPositiveTimeout(timeoutDuration); Future<T> future = executor.submit(callable); try { return amInterruptible
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 27 14:21:11 UTC 2023 - 9.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListeningExecutorService.java
*/ @Override <T extends @Nullable Object> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException; /** * Duration-based overload of {@link #invokeAll(Collection, long, TimeUnit)}. * * @since 32.1.0 */ @J2ktIncompatible default <T extends @Nullable Object> List<Future<T>> invokeAll(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 26 20:33:25 UTC 2023 - 5.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java
@Override @ParametricNullness public <T extends @Nullable Object> T callWithTimeout( Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit) throws ExecutionException { checkNotNull(callable); checkNotNull(timeoutUnit); try { return callable.call(); } catch (RuntimeException e) { throw new UncheckedExecutionException(e);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 3.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java
@Override <V extends @Nullable Object> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit); /** * Duration-based overload of {@link #schedule(Callable, long, TimeUnit)}. * * @since 29.0 */ default <V extends @Nullable Object> ListenableScheduledFuture<V> schedule( Callable<V> callable, Duration delay) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 3.6K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/api/internal/provider/DefaultProvider.java
import org.gradle.internal.Cast; import org.gradle.internal.UncheckedException; import javax.annotation.Nullable; import java.lang.reflect.ParameterizedType; import java.lang.reflect.Type; import java.util.concurrent.Callable; /** * A provider whose value is computed by a {@link Callable}. * * <h3>Configuration Cache Behavior</h3> * <b>Eager</b>. The value is computed at store time and loaded from the cache.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jan 17 23:22:41 UTC 2024 - 2.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListeningExecutorService.java
import java.util.Collection; import java.util.List; import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.TimeUnit; import org.checkerframework.checker.nullness.qual.Nullable; /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 20 10:45:35 UTC 2021 - 4.2K bytes - Viewed (0) -
platforms/core-runtime/stdlib-java-extensions/src/main/java/org/gradle/internal/UncheckedException.java
} /** * Calls the given callable converting any thrown exception to an unchecked exception via {@link UncheckedException#throwAsUncheckedException(Throwable)} * * @param callable The callable to call * @param <T> Callable's return type * @return The value returned by {@link Callable#call()} */ @Nullable public static <T> T uncheckedCall(Callable<T> callable) { try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 3.6K bytes - Viewed (0)