Home
last modified time | relevance | path

Searched refs:AtomicReference (Results 1 – 25 of 36) sorted by relevance

12

/libcore/jsr166-tests/src/test/java/jsr166/
DAtomicReferenceTest.java11 import java.util.concurrent.atomic.AtomicReference;
31 AtomicReference ai = new AtomicReference(one); in testConstructor()
39 AtomicReference ai = new AtomicReference(); in testConstructor2()
47 AtomicReference ai = new AtomicReference(one); in testGetSet()
59 AtomicReference ai = new AtomicReference(one); in testGetLazySet()
71 AtomicReference ai = new AtomicReference(one); in testCompareAndSet()
86 final AtomicReference ai = new AtomicReference(one); in testCompareAndSetInMultipleThreads()
105 AtomicReference ai = new AtomicReference(one); in testWeakCompareAndSet()
117 AtomicReference ai = new AtomicReference(one); in testGetAndSet()
127 AtomicReference x = new AtomicReference(); in testSerialization()
[all …]
DAtomic8Test.java16 import java.util.concurrent.atomic.AtomicReference;
160 AtomicReference<Integer> a = new AtomicReference<Integer>(one); in testReferenceGetAndUpdate()
171 AtomicReference<Integer> a = new AtomicReference<Integer>(one); in testReferenceUpdateAndGet()
182 AtomicReference<Integer> a = new AtomicReference<Integer>(one); in testReferenceGetAndAccumulate()
193 AtomicReference<Integer> a = new AtomicReference<Integer>(one); in testReferenceAccumulateAndGet()
504 () -> new AtomicReference().getAndUpdate(null), in testGetAndUpdateNPE()
525 () -> new AtomicReference().updateAndGet(null), in testUpdateAndGetNPE()
544 () -> new AtomicReference().getAndAccumulate(one, null), in testGetAndAccumulateNPE()
563 () -> new AtomicReference().accumulateAndGet(one, null), in testAccumulateAndGetNPE()
DThreadLocalRandomTest.java11 import java.util.concurrent.atomic.AtomicReference;
315 final AtomicReference<ThreadLocalRandom> threadLocalRandom =
316 new AtomicReference<ThreadLocalRandom>();
DJSR166TestCase.java55 import java.util.concurrent.atomic.AtomicReference;
617 private final AtomicReference<Throwable> threadFailure
618 = new AtomicReference<Throwable>(null);
/libcore/ojluni/src/test/java/util/concurrent/tck/
DAtomicReferenceTest.java37 import java.util.concurrent.atomic.AtomicReference;
54 AtomicReference ai = new AtomicReference(one); in testConstructor()
62 AtomicReference ai = new AtomicReference(); in testConstructor2()
70 AtomicReference ai = new AtomicReference(one); in testGetSet()
82 AtomicReference ai = new AtomicReference(one); in testGetLazySet()
94 AtomicReference ai = new AtomicReference(one); in testCompareAndSet()
109 final AtomicReference ai = new AtomicReference(one); in testCompareAndSetInMultipleThreads()
128 AtomicReference ai = new AtomicReference(one); in testWeakCompareAndSet()
140 AtomicReference ai = new AtomicReference(one); in testGetAndSet()
150 AtomicReference x = new AtomicReference(); in testSerialization()
[all …]
DAtomic8Test.java42 import java.util.concurrent.atomic.AtomicReference;
181 AtomicReference<Integer> a = new AtomicReference<>(one); in testReferenceGetAndUpdate()
192 AtomicReference<Integer> a = new AtomicReference<>(one); in testReferenceUpdateAndGet()
203 AtomicReference<Integer> a = new AtomicReference<>(one); in testReferenceGetAndAccumulate()
214 AtomicReference<Integer> a = new AtomicReference<>(one); in testReferenceAccumulateAndGet()
525 () -> new AtomicReference().getAndUpdate(null), in testGetAndUpdateNPE()
543 () -> new AtomicReference().updateAndGet(null), in testUpdateAndGetNPE()
562 () -> new AtomicReference().getAndAccumulate(one, null), in testGetAndAccumulateNPE()
581 () -> new AtomicReference().accumulateAndGet(one, null), in testAccumulateAndGetNPE()
DThreadLocalRandomTest.java37 import java.util.concurrent.atomic.AtomicReference;
382 final AtomicReference<ThreadLocalRandom> threadLocalRandom =
383 new AtomicReference<ThreadLocalRandom>();
DCollection8Test.java62 import java.util.concurrent.atomic.AtomicReference;
305 AtomicReference threwAt = new AtomicReference(null);
/libcore/luni/src/test/java/libcore/java/util/
DOptionalTest.java24 import java.util.concurrent.atomic.AtomicReference;
77 final AtomicReference<String> reference = new AtomicReference<>(); in testIfPresent()
102 final AtomicReference<String> reference = new AtomicReference<>(); in testFilter()
116 final AtomicReference<String> reference = new AtomicReference<>(); in testMap()
137 final AtomicReference<String> reference = new AtomicReference<>(); in testFlatMap()
DAbstractListTest.java35 import java.util.concurrent.atomic.AtomicReference;
75 AtomicReference<Integer> receivedValue = new AtomicReference<>(null); in spliterator_lateBinding()
92 AtomicReference<Integer> receivedValue = new AtomicReference<>(null); in spliterator_modification_failFast()
DOptionalDoubleTest.java26 import java.util.concurrent.atomic.AtomicReference;
55 final AtomicReference<Double> reference = new AtomicReference<>(); in testIfPresent()
/libcore/ojluni/src/main/java/java/util/concurrent/atomic/
DAtomicReference.java49 public class AtomicReference<V> implements java.io.Serializable { class
58 (AtomicReference.class.getDeclaredField("value"));
71 public AtomicReference(V initialValue) { in AtomicReference() method in AtomicReference
78 public AtomicReference() { in AtomicReference() method in AtomicReference
/libcore/luni/src/main/java/libcore/internal/
DJava9LanguageFeatures.java27 import java.util.concurrent.atomic.AtomicReference;
67 public <T> AtomicReference<T> createReference(T content) { in createReference()
69 return new AtomicReference<>(content) { }; in createReference()
/libcore/ojluni/src/main/java/java/util/stream/
DAbstractShortCircuitTask.java28 import java.util.concurrent.atomic.AtomicReference;
50 protected final AtomicReference<R> sharedResult;
71 sharedResult = new AtomicReference<>(null); in AbstractShortCircuitTask()
107 AtomicReference<R> sr = sharedResult; in compute()
/libcore/ojluni/src/main/java/java/util/concurrent/
DPhaser.java38 import java.util.concurrent.atomic.AtomicReference;
348 private final AtomicReference<QNode> evenQ;
349 private final AtomicReference<QNode> oddQ;
351 private AtomicReference<QNode> queueFor(int phase) { in queueFor()
563 this.evenQ = new AtomicReference<QNode>(); in Phaser()
564 this.oddQ = new AtomicReference<QNode>(); in Phaser()
971 AtomicReference<QNode> head = (phase & 1) == 0 ? evenQ : oddQ; in releaseWaiters()
992 AtomicReference<QNode> head = (phase & 1) == 0 ? evenQ : oddQ; in abortWait()
1054 AtomicReference<QNode> head = (phase & 1) == 0 ? evenQ : oddQ; in internalAwaitAdvance()
DConcurrentHashMap.java53 import java.util.concurrent.atomic.AtomicReference;
3766 searchFunction, new AtomicReference<U>()).invoke(); in search()
3933 searchFunction, new AtomicReference<U>()).invoke(); in searchKeys()
4120 searchFunction, new AtomicReference<U>()).invoke(); in searchValues()
4304 searchFunction, new AtomicReference<U>()).invoke(); in searchEntries()
5216 final AtomicReference<U> result;
5220 AtomicReference<U> result) { in SearchKeysTask()
5227 final AtomicReference<U> result; in compute()
5260 final AtomicReference<U> result;
5264 AtomicReference<U> result) { in SearchValuesTask()
[all …]
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/
DThreadLocalTest.java21 import java.util.concurrent.atomic.AtomicReference;
170 AtomicReference<String> threadValue = new AtomicReference<String>(); in test_withInitial()
/libcore/luni/src/test/java9language/java/libcore/libcore/internal/
DJava9LanguageFeaturesTest.java22 import java.util.concurrent.atomic.AtomicReference;
52 AtomicReference<String> ref = new Java9LanguageFeatures().createReference("Hello, world"); in testDiamondOnAnonymousClasses()
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/
DObservableTest.java23 import java.util.concurrent.atomic.AtomicReference;
242 final AtomicReference<Observable> updated = new AtomicReference<>(); in test_observableWithOverridenHasChanged()
DTimerTest.java28 import java.util.concurrent.atomic.AtomicReference;
968 final AtomicReference<Thread> threadRef = new AtomicReference<Thread>(); in testThrowingTaskKillsTimerThread()
/libcore/luni/src/test/java/libcore/java/nio/channels/
DAsynchronousServerSocketChannelTest.java42 import java.util.concurrent.atomic.AtomicReference;
282 final AtomicReference<Exception> killerThreadException = in test_future_concurrent_close()
283 new AtomicReference<Exception>(null); in test_future_concurrent_close()
312 final AtomicReference<Exception> killerThreadException = in test_completionHandler_concurrent_close()
313 new AtomicReference<Exception>(null); in test_completionHandler_concurrent_close()
DAsynchronousFileChannelTest.java47 import java.util.concurrent.atomic.AtomicReference;
646 AtomicReference<Thread> serviceThread = new AtomicReference<>(); in testCustomExecutor()
/libcore/luni/src/test/java/libcore/java/net/
DServerSocketConcurrentCloseTest.java33 import java.util.concurrent.atomic.AtomicReference;
63 final AtomicReference<Exception> failure = new AtomicReference<>(); in testImplAccept_detectsClosedState()
/libcore/luni/src/main/java/libcore/io/
DStreams.java31 import java.util.concurrent.atomic.AtomicReference;
44 private static AtomicReference<byte[]> skipBuffer = new AtomicReference<byte[]>();
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/
DSelectorTest.java32 import java.util.concurrent.atomic.AtomicReference;
358 final AtomicReference<Throwable> failure = new AtomicReference<Throwable>();

12