- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for OverflowAvoidingLockSupport (0.44 sec)
-
android/guava/src/com/google/common/util/concurrent/OverflowAvoidingLockSupport.java
*/ @J2ktIncompatible @ElementTypesAreNonnullByDefault final class OverflowAvoidingLockSupport { // Represents the max nanoseconds representable on a linux timespec with a 32 bit tv_sec static final long MAX_NANOSECONDS_THRESHOLD = (1L + Integer.MAX_VALUE) * 1_000_000_000L - 1L; private OverflowAvoidingLockSupport() {} static void parkNanos(@CheckForNull Object blocker, long nanos) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 1.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
long timeoutNanos = unit.toNanos(timeout); if (timeoutNanos <= OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD) { return super.get(timeout, unit); } // Waiting 68 years should be enough for any program. return super.get( min(timeoutNanos, OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD), NANOSECONDS); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
Waiter node = new Waiter(); do { node.setNext(oldHead); if (ATOMIC_HELPER.casWaiters(this, oldHead, node)) { while (true) { OverflowAvoidingLockSupport.parkNanos(this, remainingNanos); // Check interruption first, if we woke up due to interruption we need to honor that. if (Thread.interrupted()) { removeWaiter(node);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0)