- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for compareAndSet (0.47 sec)
-
guava/src/com/google/common/util/concurrent/AtomicDouble.java
* @return {@code true} if successful. False return indicates that the actual value was not * bitwise equal to the expected value. */ public final boolean compareAndSet(double expect, double update) { return updater.compareAndSet(this, doubleToRawLongBits(expect), doubleToRawLongBits(update)); } /** * Atomically sets the value to the given updated value if the current value is <a
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 9.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java
for (double x : VALUES) { assertBitEquals(prev, aa.get(i)); assertFalse(aa.compareAndSet(i, unused, x)); assertBitEquals(prev, aa.get(i)); assertTrue(aa.compareAndSet(i, prev, x)); assertBitEquals(x, aa.get(i)); prev = x; } } } /** compareAndSet in one thread enables another waiting for value to succeed */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 14.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
* interrupt, yet it will still run, since interruptTask will leave the runner value null, * allowing the CAS below to succeed. */ Thread currentThread = Thread.currentThread(); if (!compareAndSet(null, currentThread)) { return; // someone else has run or is running. } boolean run = !isDone(); T result = null; Throwable error = null; try { if (run) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 10K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractFutureState.java
AbstractFutureState<?> future, @Nullable Waiter expect, @Nullable Waiter update) { return waitersUpdater.compareAndSet(future, expect, update); } @Override boolean casListeners( AbstractFutureState<?> future, @Nullable Listener expect, Listener update) { return listenersUpdater.compareAndSet(future, expect, update); } @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 34.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AtomicDoubleArray.java
* @param update the new value * @return true if successful. False return indicates that the actual value was not equal to the * expected value. */ public final boolean compareAndSet(int i, double expect, double update) { return longs.compareAndSet(i, doubleToRawLongBits(expect), doubleToRawLongBits(update)); } /** * Atomically sets the element at position {@code i} to the given updated value if the current
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 10.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java
AbstractFutureState<?> future, @Nullable Waiter expect, @Nullable Waiter update) { return waitersUpdater.compareAndSet(future, expect, update); } @Override boolean casListeners( AbstractFutureState<?> future, @Nullable Listener expect, Listener update) { return listenersUpdater.compareAndSet(future, expect, update); } @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 33.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
* other callers have added to it. * * This read is guaranteed to get us the right value because we only set this once (here). * * requireNonNull is safe because either our compareAndSet succeeded or it failed because * another thread did it for us. */ seenExceptionsLocal = requireNonNull(seenExceptionsField); } return seenExceptionsLocal; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 8.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
for (int i = 0; i < 10; i++) { int expectedCount = i; list.add( new Runnable() { @Override public void run() { integer.compareAndSet(expectedCount, expectedCount + 1); } }, directExecutor()); } list.execute(); assertEquals(10, integer.get()); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 4.7K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/BloomFilterStrategies.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt
} } finally { readCompleteLatch.countDown() } } abstract fun listSource(): Source override fun ensureLoaded() { if (!listRead.get() && listRead.compareAndSet(false, true)) { readTheListUninterruptibly() } else { try { readCompleteLatch.await() } catch (_: InterruptedException) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 28 07:33:49 UTC 2025 - 3.6K bytes - Viewed (0)