- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 206 for executor (1.74 sec)
-
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* exception itself. * @param executor the executor that runs {@code fallback} if the input fails */ public <X extends Throwable> ClosingFuture<V> catching( Class<X> exceptionType, ClosingFunction<? super X, ? extends V> fallback, Executor executor) { return catchingMoreGeneric(exceptionType, fallback, executor); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 98.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Uninterruptibles.java
} /** * Invokes {@code executor.}{@link ExecutorService#awaitTermination(long, TimeUnit) * awaitTermination(long, TimeUnit)} uninterruptibly. * * @since 30.0 */ @J2ktIncompatible @GwtIncompatible // concurrency public static boolean awaitTerminationUninterruptibly( ExecutorService executor, Duration timeout) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 18.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java
public final class SimpleTimeLimiter implements TimeLimiter { private final ExecutorService executor; private SimpleTimeLimiter(ExecutorService executor) { this.executor = checkNotNull(executor); } /** * Creates a TimeLimiter instance using the given executor service to execute method calls. * * <p><b>Warning:</b> using a bounded executor may be counterproductive! If the thread pool fills
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 27 14:21:11 UTC 2023 - 9.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
ScheduledExecutorService executor = newScheduledThreadPool(1); try { FluentFuture<?> f = FluentFuture.from(SettableFuture.create()).withTimeout(0, SECONDS, executor); ExecutionException e = assertThrows(ExecutionException.class, () -> f.get()); assertThat(e).hasCauseThat().isInstanceOf(TimeoutException.class); } finally { executor.shutdown(); } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 5.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertWithMessage; import java.util.concurrent.Executor; import java.util.concurrent.Future; import junit.framework.TestCase; /** Test for {@link ListenableFuture}. */ public class ListenableFutureTest extends TestCase { public void testNoNewApis() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Jun 15 19:48:16 UTC 2023 - 1.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
} /** * Adds a listener that will be called using the given executor when events are later {@link * #enqueue enqueued} and {@link #dispatch dispatched}. */ public void addListener(L listener, Executor executor) { checkNotNull(listener, "listener"); checkNotNull(executor, "executor"); listeners.add(new PerListenerQueue<>(listener, executor)); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 8.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java
import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; /** * Tests for {@link ClosingFuture} that exercise {@link * ClosingFuture#finishToValueAndCloser(ValueAndCloserConsumer, Executor)}. */ public class ClosingFutureFinishToValueAndCloserTest extends AbstractClosingFutureTest {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 5.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
// avoid unintended usage. // The execution list to hold our listeners. private final ExecutionList executionList = new ExecutionList(); /** * Creates a {@code ListenableFutureTask} that will upon running, execute the given {@code * Callable}. * * @param callable the callable task * @since 10.0 */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 4.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* @param executor the executor in which the listeners callback methods will be run. For fast, * lightweight listeners that would be safe to execute in any thread, consider {@link * MoreExecutors#directExecutor}. * @since 13.0 */ void addListener(Listener listener, Executor executor); /** * The lifecycle states of a service. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 10.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ImmediateFuture.java
public void addListener(Runnable listener, Executor executor) { checkNotNull(listener, "Runnable was null."); checkNotNull(executor, "Executor was null."); try { executor.execute(listener); } catch (Exception e) { // sneaky checked exception // ListenableFuture's contract is that it will not throw unchecked exceptions, so log the bad // runnable and/or executor and swallow it. log.get() .log(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 3.5K bytes - Viewed (0)