Home
last modified time | relevance | path

Searched refs:AtomicReference (Results 1 – 25 of 41) 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;
356 final AtomicReference<ThreadLocalRandom> threadLocalRandom =
357 new AtomicReference<ThreadLocalRandom>();
/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>();
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DAtomicReferenceTest.java23 import java.util.concurrent.atomic.AtomicReference;
34 AtomicReference<Integer> val = new AtomicReference(currentValue); in testCompareAndExchange()
79 AtomicReference<Integer> val = new AtomicReference(currentValue); in testCompareAndExchangeAcquire()
124 AtomicReference<Integer> val = new AtomicReference(currentValue); in testCompareAndExchangeRelease()
169 AtomicReference<Integer> val = new AtomicReference(currentValue); in testGetAcquire()
187 AtomicReference<Integer> val = new AtomicReference(currentValue); in testGetOpaque()
205 AtomicReference<Integer> val = new AtomicReference(currentValue); in testGetPlain()
223 AtomicReference<Integer> val = new AtomicReference(currentValue); in testSetOpaque()
241 AtomicReference<Integer> val = new AtomicReference(currentValue); in testSetPlain()
259 AtomicReference<Integer> val = new AtomicReference(currentValue); in testSetRelease()
[all …]
DFutureTaskTest.java24 import java.util.concurrent.atomic.AtomicReference;
45 static class TestCallable extends AtomicReference<FutureTask> implements Callable<Integer> {
/libcore/luni/src/test/java/libcore/java/util/
DOptionalTest.java24 import java.util.concurrent.atomic.AtomicReference;
78 final AtomicReference<String> reference = new AtomicReference<>(); in testIfPresent()
103 final AtomicReference<String> reference = new AtomicReference<>(); in testFilter()
117 final AtomicReference<String> reference = new AtomicReference<>(); in testMap()
138 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/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<>(); in AbstractShortCircuitTask()
107 AtomicReference<R> sr = sharedResult; in compute()
/libcore/ojluni/src/main/java/java/util/concurrent/atomic/
DAtomicReference.java51 public class AtomicReference<V> implements java.io.Serializable { class
57 VALUE = l.findVarHandle(AtomicReference.class, "value", Object.class);
71 public AtomicReference(V initialValue) { in AtomicReference() method in AtomicReference
78 public AtomicReference() { in AtomicReference() method in AtomicReference
/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/ojluni/src/main/java/java/util/concurrent/
DPhaser.java40 import java.util.concurrent.atomic.AtomicReference;
351 private final AtomicReference<QNode> evenQ;
352 private final AtomicReference<QNode> oddQ;
562 this.evenQ = new AtomicReference<QNode>(); in Phaser()
563 this.oddQ = new AtomicReference<QNode>(); in Phaser()
970 AtomicReference<QNode> head = (phase & 1) == 0 ? evenQ : oddQ; in releaseWaiters()
991 AtomicReference<QNode> head = (phase & 1) == 0 ? evenQ : oddQ; in abortWait()
1056 AtomicReference<QNode> head = (phase & 1) == 0 ? evenQ : oddQ; in internalAwaitAdvance()
/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/luni/src/main/java/libcore/io/
DStreams.java31 import java.util.concurrent.atomic.AtomicReference;
43 private static AtomicReference<byte[]> skipBuffer = new AtomicReference<byte[]>();
/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()
/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.java49 import java.util.concurrent.atomic.AtomicReference;
648 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/ojluni/src/test/java/lang/StackWalker/
DDumpStackTest.java41 import java.util.concurrent.atomic.AtomicReference;
113 AtomicReference<Throwable> th = new AtomicReference<>(); in testThread()
/libcore/luni/src/test/java/libcore/java/io/
DFileTest.java31 import java.util.concurrent.atomic.AtomicReference;
359 AtomicReference<Throwable> pendingThrowable = new AtomicReference<>(); in testExistsOnSystem()
/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