- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 19 for compareAndSet (0.07 seconds)
-
android/guava/src/com/google/common/util/concurrent/AtomicLongMap.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed May 14 13:21:19 GMT 2025 - 14K bytes - Click Count (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 */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 14.8K bytes - Click Count (0) -
android/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 */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 10.8K bytes - Click Count (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) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 10K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java
assertBitEquals(x, at.doubleValue()); } } /** compareAndSet treats +0.0 and -0.0 as distinct values */ public void testDistinctZeros() { AtomicDouble at = new AtomicDouble(+0.0); assertFalse(at.compareAndSet(-0.0, 7.0)); assertFalse(at.weakCompareAndSet(-0.0, 7.0)); assertBitEquals(+0.0, at.get()); assertTrue(at.compareAndSet(+0.0, -0.0)); assertBitEquals(-0.0, at.get());
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 10.6K bytes - Click Count (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
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 33.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
executingTaskQueue.thread = null; } } private boolean trySetStarted() { return compareAndSet(NOT_RUN, STARTED); } private boolean trySetCancelled() { return compareAndSet(NOT_RUN, CANCELLED); } }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java
* AtomicInteger's atomic operations, with some help from ConcurrentMap's atomic operations on * creation and removal (including automatic removal of zeroes). If the modification of an * AtomicInteger results in zero, we compareAndSet the value to zero; if that succeeds, we remove * the entry from the Map. If another operation sees a zero in the map, it knows that the entry is
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 26 20:08:09 GMT 2025 - 22.3K bytes - Click Count (0) -
guava/src/com/google/common/collect/ConcurrentHashMultiset.java
* AtomicInteger's atomic operations, with some help from ConcurrentMap's atomic operations on * creation and removal (including automatic removal of zeroes). If the modification of an * AtomicInteger results in zero, we compareAndSet the value to zero; if that succeeds, we remove * the entry from the Map. If another operation sees a zero in the map, it knows that the entry is
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 26 20:08:09 GMT 2025 - 22.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java
} /** * Simulate some of the races that can happen on add. We can't easily simulate the race that * happens when an {@link AtomicInteger#compareAndSet} fails, but we can simulate the case where * the putIfAbsent returns a non-null value, and the case where the replace() of an observed zero * fails. */ public void testAdd_withFailures() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 16.3K bytes - Click Count (0)