Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for getUninterruptibly (0.08 sec)

  1. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      @CanIgnoreReturnValue
      @J2ktIncompatible
      @GwtIncompatible // java.time.Duration
      @ParametricNullness
      public static <V extends @Nullable Object> V getUninterruptibly(
          Future<V> future, Duration timeout) throws ExecutionException, TimeoutException {
        return getUninterruptibly(future, toNanosSaturated(timeout), TimeUnit.NANOSECONDS);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      @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), TimeUnit.NANOSECONDS);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  3. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        Runnable collectResultsRunnable =
            new Runnable() {
              @Override
              public void run() {
                try {
                  String result = Uninterruptibles.getUninterruptibly(currentFuture.get());
                  finalResults.add(result);
                } catch (ExecutionException e) {
                  finalResults.add(e.getCause());
                } catch (CancellationException e) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
Back to top