Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 18 for getUninterruptibly (0.3 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java

        repeatedlyInterruptTestThread(tearDownStack);
    
        assertThrows(
            TimeoutException.class, () -> getUninterruptibly(delayedFuture, 500, MILLISECONDS));
        assertTrue(Thread.interrupted()); // clears the interrupt state, too
    
        assertFalse(sleeper.completed);
        assertTrue(getUninterruptibly(delayedFuture));
    
        assertTrue(Thread.interrupted()); // clears the interrupt state, too
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.9K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/TestPlatform.java

    import static com.google.common.base.Preconditions.checkState;
    import static com.google.common.util.concurrent.FuturesTest.pseudoTimedGetUninterruptibly;
    import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static junit.framework.Assert.assertFalse;
    import static junit.framework.Assert.fail;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java

        repeatedlyInterruptTestThread(tearDownStack);
    
        assertThrows(
            TimeoutException.class, () -> getUninterruptibly(delayedFuture, 500, MILLISECONDS));
        assertTrue(Thread.interrupted()); // clears the interrupt state, too
    
        assertFalse(sleeper.completed);
        assertTrue(getUninterruptibly(delayedFuture));
    
        assertTrue(Thread.interrupted()); // clears the interrupt state, too
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.9K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java

    import static com.google.common.util.concurrent.Futures.immediateFuture;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import java.io.Closeable;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java

    import static com.google.common.base.Preconditions.checkArgument;
    import static com.google.common.base.Preconditions.checkNotNull;
    import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.collect.ObjectArrays;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 9.6K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      @ParametricNullness
      @IgnoreJRERequirement // Users will use this only if they're already using Duration.
      public static <V extends @Nullable Object> V getUninterruptibly(
          Future<V> future, Duration timeout) throws ExecutionException, TimeoutException {
        return getUninterruptibly(future, toNanosSaturated(timeout), NANOSECONDS);
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 23:24:32 GMT 2026
    - 22.5K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java

    import static com.google.common.util.concurrent.Futures.immediateFuture;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import java.io.Closeable;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  8. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/Uninterruptibles.java

    /** Emulation of Uninterruptibles in GWT. */
    public final class Uninterruptibles {
    
      private Uninterruptibles() {}
    
      @CanIgnoreReturnValue
      public static <V extends @Nullable Object> V getUninterruptibly(Future<V> future)
          throws ExecutionException {
        try {
          return future.get();
        } catch (InterruptedException e) {
          // Should never be thrown in GWT but play it safe
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 1.3K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

        try {
          // We get the result, even if collectOneValue is a no-op, so that we can fail fast.
          // We use getUninterruptibly over getDone as a micro-optimization, we know the future is done.
          collectOneValue(index, getUninterruptibly(future));
        } catch (ExecutionException e) {
          handleException(e.getCause());
        } catch (Throwable t) { // sneaky checked exception
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 16K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

        try {
          getUninterruptibly(future);
          fail("Expected future to fail: " + future);
        } catch (ExecutionException e) {
          assertThat(e).hasCauseThat().isSameInstanceAs(exception);
        }
      }
    
      static void assertThatFutureBecomesCancelled(Future<?> future) throws ExecutionException {
        try {
          getUninterruptibly(future);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 63K bytes
    - Click Count (0)
Back to Top