Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 130 for ExecutionException (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top