- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for getUninterruptibly (0.45 sec)
-
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) -
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) -
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) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 47.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
import static com.google.common.util.concurrent.Internal.toNanosSaturated; 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 com.google.common.annotations.GwtCompatible; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
import static com.google.common.util.concurrent.Internal.toNanosSaturated; 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 com.google.common.annotations.GwtCompatible; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.4K bytes - Viewed (0) -
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;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 149.2K bytes - Viewed (0)