Home
last modified time | relevance | path

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

/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);
DCompletableFutureTest.java38 import java.util.concurrent.atomic.AtomicReference;
3350 AtomicReference<Throwable> r = new AtomicReference<Throwable>(); in testCompletedStage()
3428 AtomicReference<Throwable> r = new AtomicReference<Throwable>(); in testMinimalCompletionStage()
3445 AtomicReference<Throwable> r = new AtomicReference<Throwable>(); in testMinimalCompletionStage2()
3463 AtomicReference<Throwable> r = new AtomicReference<Throwable>(); in testFailedStage()
3836 AtomicReference<Throwable> firstFailure = new AtomicReference<>(null);
DCountedCompleterTest.java20 import java.util.concurrent.atomic.AtomicReference;
217 final AtomicReference<Object> rawResult = new AtomicReference<Object>(null);
/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/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()
DOptionalDoubleTest.java26 import java.util.concurrent.atomic.AtomicReference;
55 final AtomicReference<Double> reference = new AtomicReference<>(); in testIfPresent()
/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;
3764 searchFunction, new AtomicReference<U>()).invoke(); in search()
3931 searchFunction, new AtomicReference<U>()).invoke(); in searchKeys()
4118 searchFunction, new AtomicReference<U>()).invoke(); in searchValues()
4302 searchFunction, new AtomicReference<U>()).invoke(); in searchEntries()
5214 final AtomicReference<U> result;
5218 AtomicReference<U> result) { in SearchKeysTask()
5225 final AtomicReference<U> result; in compute()
5258 final AtomicReference<U> result;
5262 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/main/java/libcore/io/
DStreams.java27 import java.util.concurrent.atomic.AtomicReference;
30 private static AtomicReference<byte[]> skipBuffer = new AtomicReference<byte[]>();
/libcore/luni/src/test/java/libcore/java/net/
DServerSocketConcurrentCloseTest.java14 import java.util.concurrent.atomic.AtomicReference;
44 final AtomicReference<Exception> failure = new AtomicReference<>(); in testImplAccept_detectsClosedState()
DURLConnectionTest.java73 import java.util.concurrent.atomic.AtomicReference;
1116 final AtomicReference<HttpURLConnection> connectionHolder = new AtomicReference<>(); in checkDisconnectDuringConnect()
2475 final AtomicReference<URI> uriReference = new AtomicReference<URI>();
/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/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>();
DDatagramChannelTest.java38 import java.util.concurrent.atomic.AtomicReference;
2534 … final AtomicReference<Exception> killerThreadException = new AtomicReference<Exception>(null); in test_concurrentShutdown()
/libcore/luni/src/test/java/libcore/io/
DOsTest.java46 import java.util.concurrent.atomic.AtomicReference;
474 final AtomicReference<Exception> killerThreadException = new AtomicReference<Exception>(null); in test_recvfrom_concurrentShutdown()
/libcore/
Dopenjdk_java_files.mk986 ojluni/src/main/java/java/util/concurrent/atomic/AtomicReference.java \