Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for awaitUninterruptibly (0.23 sec)

  1. guava-tests/test/com/google/common/collect/MapMakerTest.java

     */
    
    package com.google.common.collect;
    
    import static com.google.common.collect.ReflectionFreeAssertThrows.assertThrows;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.base.Function;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 15 17:36:06 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

       * uninterruptibly.
       *
       * @since 28.0 (but only since 33.4.0 in the Android flavor)
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      public static boolean awaitUninterruptibly(CountDownLatch latch, Duration timeout) {
        return awaitUninterruptibly(latch, toNanosSaturated(timeout), TimeUnit.NANOSECONDS);
      }
    
      /**
       * Invokes {@code latch.}{@link CountDownLatch#await(long, TimeUnit) await(timeout, unit)}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

              public void run() {
                task.run();
              }
            });
        awaitUninterruptibly(doingCallLatch);
        long hangDelayMillis =
            (expectedOutcome == Outcome.HANG)
                ? EXPECTED_HANG_DELAY_MILLIS
                : UNEXPECTED_HANG_DELAY_MILLIS;
        boolean hung =
            !awaitUninterruptibly(callCompletedLatch, hangDelayMillis, TimeUnit.MILLISECONDS);
        if (hung) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      @GwtIncompatible // concurrency
      @SuppressWarnings("Java7ApiChecker")
      @IgnoreJRERequirement // Users will use this only if they're already using Duration.
      public static boolean awaitUninterruptibly(CountDownLatch latch, Duration timeout) {
        return awaitUninterruptibly(latch, toNanosSaturated(timeout), TimeUnit.NANOSECONDS);
      }
    
      /**
       * Invokes {@code latch.}{@link CountDownLatch#await(long, TimeUnit) await(timeout, unit)}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/collect/MapMakerTest.java

     */
    
    package com.google.common.collect;
    
    import static com.google.common.collect.ReflectionFreeAssertThrows.assertThrows;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.base.Function;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 15 17:36:06 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

              public void run() {
                task.run();
              }
            });
        awaitUninterruptibly(doingCallLatch);
        long hangDelayMillis =
            (expectedOutcome == Outcome.HANG)
                ? EXPECTED_HANG_DELAY_MILLIS
                : UNEXPECTED_HANG_DELAY_MILLIS;
        boolean hung =
            !awaitUninterruptibly(callCompletedLatch, hangDelayMillis, TimeUnit.MILLISECONDS);
        if (hung) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

    import static com.google.common.util.concurrent.Futures.transformAsync;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.util.concurrent.ForwardingListenableFuture.SimpleForwardingListenableFuture;
    import java.util.concurrent.CancellationException;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

    import static com.google.common.util.concurrent.Futures.transformAsync;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.util.concurrent.ForwardingListenableFuture.SimpleForwardingListenableFuture;
    import java.util.concurrent.CancellationException;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.MoreExecutors.newSequentialExecutor;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.collect.ImmutableList;
    import com.google.common.collect.Lists;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.MoreExecutors.newSequentialExecutor;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.collect.ImmutableList;
    import com.google.common.collect.Lists;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
Back to top