- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 124 for ExecutionException (0.6 sec)
-
android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
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) throws InterruptedException, ExecutionException, TimeoutException {Registered: Fri Dec 26 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
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) throws InterruptedException, ExecutionException, TimeoutException {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:37:28 UTC 2025 - 6.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FakeTimeLimiterTest.java
} public void testCallWithTimeout_wrapsCheckedException() throws Exception { Exception exception = new SampleCheckedException(); ExecutionException e = assertThrows( ExecutionException.class, () -> timeLimiter.callWithTimeout(callableThrowing(exception), DELAY_MS, MILLISECONDS)); assertThat(e).hasCauseThat().isEqualTo(exception); }
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 4.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* cancelled. * * <p>If the combiner throws an {@code ExecutionException}, the cause of the thrown {@code * ExecutionException} will be extracted and returned as the cause of the new {@code * ExecutionException} that gets thrown by the returned combined future. * * <p>Canceling this future will attempt to cancel all the component futures.Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
throws ExecutionException, InterruptedException { assertTaskWrapped(tasks); lastMethodCalled = "invokeAny"; return inline.submit(Iterables.get(tasks, 0)).get(); } @Override public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws ExecutionException, InterruptedException, TimeoutException {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 9.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestPlatform.java
fail(); } catch (TimeoutException expected) { } catch (ExecutionException e) { throw new AssertionError(e); } } static void verifyTimedGetOnPendingFuture(Future<?> future) { try { getUninterruptibly(future, 0, SECONDS); fail(); } catch (TimeoutException expected) { } catch (ExecutionException e) { throw new AssertionError(e); } }
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 2.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java
throws InterruptedException, ExecutionException { assertTrue(future.isDone()); assertFalse(future.isCancelled()); assertTrue(latch.await(5, SECONDS)); assertTrue(future.isDone()); assertFalse(future.isCancelled()); assertEquals(expectedValue, future.get()); } public void testCancelledFuture() throws InterruptedException, ExecutionException { assertTrue(future.isDone());Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 3.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
throw e; } }); task.run(); assertTrue(task.isDone()); assertFalse(task.isCancelled()); ExecutionException executionException = assertThrows(ExecutionException.class, () -> getDone(task)); assertThat(executionException).hasCauseThat().isEqualTo(e); } @J2ktIncompatible @GwtIncompatible // blocking wait public void testCancel_interrupted() throws Exception {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 7.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
}; AsyncCallable<String> asyncCallable = Callables.asAsyncCallable(callable, newDirectExecutorService()); ListenableFuture<String> future = asyncCallable.call(); ExecutionException e = assertThrows(ExecutionException.class, () -> future.get()); assertThat(e).hasCauseThat().isSameInstanceAs(expected); } @J2ktIncompatible @GwtIncompatible // threads public void testRenaming() throws Exception {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 4.4K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/LocalCache.java
public V get(K key, Callable<? extends V> valueLoader) throws ExecutionException { V value = localCache.get(key); if (value != null) { return value; } try { V newValue = valueLoader.call(); localCache.put(key, newValue); return newValue; } catch (Exception e) { throw new ExecutionException(e); } } @Override
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 21.8K bytes - Viewed (0)