Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 124 for ExecutionException (0.06 sec)

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