- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 130 for ExecutionException (0.09 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
public void testFutureGetThrowsRuntimeException() throws Exception { BadFuture badInput = new BadFuture(immediateFuture(20)); ListenableFuture<String> chain = buildChainingFuture(badInput); ExecutionException e = assertThrows(ExecutionException.class, () -> chain.get()); assertSame(RuntimeException.class, e.getCause().getClass()); } /** Proxy to throw a {@link RuntimeException} out of the {@link #get()} method. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 6.2K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/ReflectionFreeAssertThrows.java
.put( ConcurrentModificationException.class, e -> e instanceof ConcurrentModificationException) .put(ExecutionException.class, e -> e instanceof ExecutionException) .put(IllegalArgumentException.class, e -> e instanceof IllegalArgumentException) .put(IllegalStateException.class, e -> e instanceof IllegalStateException)
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 20:00:30 UTC 2024 - 6.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/ReflectionFreeAssertThrows.java
.put( ConcurrentModificationException.class, e -> e instanceof ConcurrentModificationException) .put(ExecutionException.class, e -> e instanceof ExecutionException) .put(IllegalArgumentException.class, e -> e instanceof IllegalArgumentException) .put(IllegalStateException.class, e -> e instanceof IllegalStateException)
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 16:27:30 UTC 2024 - 6.3K bytes - Viewed (0) -
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: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 5.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
public void testFutureGetThrowsRuntimeException() throws Exception { BadFuture badInput = new BadFuture(immediateFuture(20)); ListenableFuture<String> chain = buildChainingFuture(badInput); ExecutionException e = assertThrows(ExecutionException.class, () -> chain.get()); assertSame(RuntimeException.class, e.getCause().getClass()); } /** Proxy to throw a {@link RuntimeException} out of the {@link #get()} method. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 6.2K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlFilterService.java
return includeFilterCache.get(sessionId); } catch (final ExecutionException e) { throw new CrawlerSystemException(e); } } @Override public List<Pattern> getExcludeUrlPatternList(final String sessionId) { try { return excludeFilterCache.get(sessionId); } catch (final ExecutionException e) { throw new CrawlerSystemException(e); }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 6.3K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/SingleThreadAbstractFutureBenchmark.java
import com.google.common.util.concurrent.AbstractFutureBenchmarks.Impl; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CancellationException; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeoutException; /** A benchmark that times how long it takes to add a given number of */ @VmOptions({"-Xms8g", "-Xmx8g"}) public class SingleThreadAbstractFutureBenchmark {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 3.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ReflectionFreeAssertThrows.java
.put( ConcurrentModificationException.class, e -> e instanceof ConcurrentModificationException) .put(ExecutionException.class, e -> e instanceof ExecutionException) .put(IllegalArgumentException.class, e -> e instanceof IllegalArgumentException) .put(IllegalStateException.class, e -> e instanceof IllegalStateException)
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 19:43:49 UTC 2024 - 7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
* Futures#getUnchecked}. * </ul> * * @throws ExecutionException if the computation threw an exception * @throws CancellationException if the computation was cancelled */ @CanIgnoreReturnValue @ParametricNullness public static <V extends @Nullable Object> V getUninterruptibly(Future<V> future) throws ExecutionException { boolean interrupted = false; try { while (true) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 20.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
@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) throws ExecutionException, InterruptedException, TimeoutException { throw new UnsupportedOperationException(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 7.6K bytes - Viewed (0)