Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 60 for uninterruptible (0.39 seconds)

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

                } catch (InterruptedException e) {
                  return;
                }
              }
            };
        waiter.start();
        awaitTimedWaiting(waiter);
        service.shutdown();
        Uninterruptibles.joinUninterruptibly(waiter, 10, SECONDS);
        if (waiter.isAlive()) {
          waiter.interrupt();
          fail("awaitTermination failed to trigger after shutdown()");
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

              return stopwatch.elapsed(MICROSECONDS);
            }
    
            @Override
            protected void sleepMicrosUninterruptibly(long micros) {
              if (micros > 0) {
                Uninterruptibles.sleepUninterruptibly(micros, MICROSECONDS);
              }
            }
          };
        }
      }
    
      private static void checkPermits(int permits) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 20:05:27 GMT 2025
    - 21.8K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

    import static com.google.common.util.concurrent.MoreExecutors.shutdownAndAwaitTermination;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;
    import static java.util.Arrays.asList;
    import static java.util.concurrent.Executors.newSingleThreadExecutor;
    import static java.util.concurrent.TimeUnit.SECONDS;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 63K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

    import static com.google.common.util.concurrent.AggregateFuture.ReleaseResourcesReason.OUTPUT_FUTURE_DONE;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;
    import static java.util.Objects.requireNonNull;
    import static java.util.logging.Level.SEVERE;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.collect.ImmutableCollection;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 16K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

    import static com.google.common.util.concurrent.MoreExecutors.shutdownAndAwaitTermination;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;
    import static java.util.Arrays.asList;
    import static java.util.concurrent.Executors.newSingleThreadExecutor;
    import static java.util.concurrent.TimeUnit.SECONDS;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 63K bytes
    - Click Count (0)
  6. guava/src/com/google/common/cache/LocalCache.java

    import static com.google.common.util.concurrent.Futures.transform;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;
    import static java.lang.Math.min;
    import static java.util.Collections.unmodifiableSet;
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    
    import com.google.common.annotations.GwtCompatible;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 148.9K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/cache/LocalCache.java

    import static com.google.common.util.concurrent.Futures.transform;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;
    import static java.lang.Math.min;
    import static java.util.Collections.unmodifiableSet;
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    
    import com.google.common.annotations.GwtCompatible;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 143.5K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

          return new Cancellation(false, cancellation);
        } catch (Exception | Error t) { // sneaky checked exception
          return new Failure(t);
        }
      }
    
      /**
       * An inlined private copy of {@link Uninterruptibles#getUninterruptibly} used to break an
       * internal dependency on other /util/concurrent classes.
       */
      @ParametricNullness
      private static <V extends @Nullable Object> V getUninterruptibly(Future<V> future)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 43.6K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

    import static com.google.common.util.concurrent.TestPlatform.getDoneFromTimeoutOverload;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;
    import static com.google.common.util.concurrent.testing.TestingExecutors.noOpScheduledExecutor;
    import static java.util.Arrays.asList;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

    import static com.google.common.util.concurrent.TestPlatform.getDoneFromTimeoutOverload;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;
    import static com.google.common.util.concurrent.testing.TestingExecutors.noOpScheduledExecutor;
    import static java.util.Arrays.asList;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
Back to Top