Home
last modified time | relevance | path

Searched refs:LockSupport (Results 1 – 25 of 26) sorted by relevance

12

/libcore/luni/src/test/java/libcore/java/util/concurrent/
DLockSupportTest.java22 import java.util.concurrent.locks.LockSupport;
33 LockSupport.setCurrentBlocker(val); in testSetCurrentBlocker()
34 assertSame(val, LockSupport.getBlocker(Thread.currentThread())); in testSetCurrentBlocker()
35 LockSupport.setCurrentBlocker(null); in testSetCurrentBlocker()
36 assertNull(LockSupport.getBlocker(Thread.currentThread())); in testSetCurrentBlocker()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DLockSupportTest.java42 import java.util.concurrent.locks.LockSupport;
59 Class<?> ensureLoaded = LockSupport.class;
73 LockSupport.park(); in park()
81 LockSupport.parkUntil(deadline(millis)); in parkUntil()
86 LockSupport.parkNanos(MILLISECONDS.toNanos(millis)); in parkNanos()
91 LockSupport.park(theBlocker()); in parkBlocker()
99 LockSupport.parkUntil(theBlocker(), deadline(millis)); in parkUntilBlocker()
104 LockSupport.parkNanos(theBlocker(), in parkNanosBlocker()
149 LockSupport.unpark(t); in testParkBeforeUnpark()
186 LockSupport.unpark(t); in testParkAfterUnpark()
[all …]
/libcore/jsr166-tests/src/test/java/jsr166/
DLockSupportTest.java16 import java.util.concurrent.locks.LockSupport;
35 Class<?> ensureLoaded = LockSupport.class;
49 LockSupport.park(); in park()
57 LockSupport.parkUntil(deadline(millis)); in parkUntil()
62 LockSupport.parkNanos(MILLISECONDS.toNanos(millis)); in parkNanos()
67 LockSupport.park(theBlocker()); in parkBlocker()
75 LockSupport.parkUntil(theBlocker(), deadline(millis)); in parkUntilBlocker()
80 LockSupport.parkNanos(theBlocker(), in parkNanosBlocker()
125 LockSupport.unpark(t); in testParkBeforeUnpark()
162 LockSupport.unpark(t); in testParkAfterUnpark()
[all …]
/libcore/ojluni/src/main/java/java/util/concurrent/
DExchanger.java41 import java.util.concurrent.locks.LockSupport;
369 LockSupport.unpark(w); in arenaExchange()
401 LockSupport.park(this); in arenaExchange()
403 LockSupport.parkNanos(this, ns); in arenaExchange()
466 LockSupport.unpark(w); in slotExchange()
504 LockSupport.park(this); in slotExchange()
506 LockSupport.parkNanos(this, ns); in slotExchange()
DSynchronousQueue.java48 import java.util.concurrent.locks.LockSupport;
263 LockSupport.unpark(w); in tryMatch()
288 while (!isReleasable()) LockSupport.park(); in block()
395 LockSupport.setCurrentBlocker(this); in transfer()
399 LockSupport.setCurrentBlocker(null); in transfer()
401 LockSupport.parkNanos(this, nanos); in transfer()
562 while (!isReleasable()) LockSupport.park(); in block()
697 LockSupport.setCurrentBlocker(this); in transfer()
701 LockSupport.setCurrentBlocker(null); in transfer()
704 LockSupport.parkNanos(this, nanos); in transfer()
[all …]
DFutureTask.java40 import java.util.concurrent.locks.LockSupport;
369 LockSupport.unpark(t); in finishCompletion()
444 LockSupport.parkNanos(this, parkNanos); in awaitDone()
447 LockSupport.park(this); in awaitDone()
539 Class<?> ensureLoaded = LockSupport.class;
DPhaser.java41 import java.util.concurrent.locks.LockSupport;
976 LockSupport.unpark(t); in releaseWaiters()
1000 LockSupport.unpark(t); in abortWait()
1132 LockSupport.parkNanos(this, nanos); in block()
1134 LockSupport.park(this); in block()
1152 Class<?> ensureLoaded = LockSupport.class;
DForkJoinTask.java45 import java.util.concurrent.locks.LockSupport;
295 LockSupport.unpark(t); // don't self-signal in signalWaiters()
345 LockSupport.unpark(p.thread); in trySetThrown()
469 LockSupport.parkNanos(ns); in awaitDone()
472 LockSupport.park(); in awaitDone()
479 LockSupport.setCurrentBlocker(this); in awaitDone()
493 LockSupport.setCurrentBlocker(null); in awaitDone()
DLinkedTransferQueue.java49 import java.util.concurrent.locks.LockSupport;
448 LockSupport.unpark(waiter); in tryMatch()
470 while (!isReleasable()) LockSupport.park(); in block()
667 LockSupport.setCurrentBlocker(this); in awaitMatch()
671 LockSupport.setCurrentBlocker(null); in awaitMatch()
676 LockSupport.parkNanos(this, nanos); in awaitMatch()
1664 Class<?> ensureLoaded = LockSupport.class;
DSubmissionPublisher.java43 import java.util.concurrent.locks.LockSupport;
1439 LockSupport.unpark(w); in signalWaiter()
1493 LockSupport.parkNanos(this, nanos); in block()
1495 LockSupport.park(this); in block()
1521 Class<?> ensureLoaded = LockSupport.class;
DForkJoinPool.java53 import java.util.concurrent.locks.LockSupport;
1606 LockSupport.unpark(vt); // release idle worker
1686 LockSupport.setCurrentBlocker(this); // prepare to block (exit also OK)
1727 LockSupport.park();
1729 LockSupport.parkUntil(deadline);
1801 LockSupport.unpark(vt);
2088 LockSupport.parkNanos(this, parkTime);
2121 LockSupport.parkNanos(this, parkTime);
3496 Class<?> ensureLoaded = LockSupport.class;
DCompletableFuture.java40 import java.util.concurrent.locks.LockSupport;
1824 LockSupport.unpark(w); in tryFire()
1840 LockSupport.park(this); in block()
1842 LockSupport.parkNanos(this, nanos); in block()
2961 Class<?> ensureLoaded = LockSupport.class;
DConcurrentHashMap.java54 import java.util.concurrent.locks.LockSupport;
2887 LockSupport.park(this); in contendedLock()
2916 LockSupport.unpark(w); in find()
6382 Class<?> ensureLoaded = LockSupport.class;
/libcore/ojluni/src/main/java/java/util/concurrent/locks/
DAbstractQueuedSynchronizer.java506 while (!isReleasable()) LockSupport.park(); in block()
586 LockSupport.unpark(node.waiter); in enqueue()
611 LockSupport.unpark(s.waiter); in signalNext()
621 LockSupport.unpark(s.waiter); in signalNextIfShared()
715 LockSupport.park(this); in acquire()
717 LockSupport.parkNanos(this, nanos); in acquire()
1568 LockSupport.setCurrentBlocker(this); // for back-compatibility in awaitUninterruptibly()
1587 LockSupport.setCurrentBlocker(null); in awaitUninterruptibly()
1612 LockSupport.setCurrentBlocker(this); // for back-compatibility in await()
1632 LockSupport.setCurrentBlocker(null); in await()
[all …]
DAbstractQueuedLongSynchronizer.java141 while (!isReleasable()) LockSupport.park(); in block()
221 LockSupport.unpark(node.waiter); in enqueue()
246 LockSupport.unpark(s.waiter); in signalNext()
256 LockSupport.unpark(s.waiter); in signalNextIfShared()
350 LockSupport.park(this); in acquire()
352 LockSupport.parkNanos(this, nanos); in acquire()
1202 LockSupport.setCurrentBlocker(this); // for back-compatibility in awaitUninterruptibly()
1221 LockSupport.setCurrentBlocker(null); in awaitUninterruptibly()
1246 LockSupport.setCurrentBlocker(this); // for back-compatibility in await()
1266 LockSupport.setCurrentBlocker(null); in await()
[all …]
DReentrantReadWriteLock.java280 final long tid = LockSupport.getThreadId(Thread.currentThread());
426 rh.tid != LockSupport.getThreadId(current)) in tryReleaseShared()
486 rh.tid != LockSupport.getThreadId(current)) in tryAcquireShared()
524 rh.tid != LockSupport.getThreadId(current)) { in fullTryAcquireShared()
546 rh.tid != LockSupport.getThreadId(current)) in fullTryAcquireShared()
605 rh.tid != LockSupport.getThreadId(current)) in tryReadLock()
656 if (rh != null && rh.tid == LockSupport.getThreadId(current)) in getReadHoldCount()
DLockSupport.java139 public class LockSupport { class
140 private LockSupport() {} // Cannot be instantiated. in LockSupport() method in LockSupport
DStampedLock.java1163 LockSupport.unpark(s.waiter); in signalNext()
1174 LockSupport.unpark(c.waiter); in signalCowaiters()
1251 LockSupport.park(this); in acquireWrite()
1253 LockSupport.parkNanos(this, nanos); in acquireWrite()
1318 LockSupport.park(this); in acquireRead()
1320 LockSupport.parkNanos(this, nanos); in acquireRead()
1378 LockSupport.park(this); in acquireRead()
1380 LockSupport.parkNanos(this, nanos); in acquireRead()
1496 Class<?> ensureLoaded = LockSupport.class;
/libcore/luni/src/test/java/libcore/java/lang/
DThreadTest.java35 import java.util.concurrent.locks.LockSupport;
441 LockSupport.unpark(current); in parkUntilWithUnderflowValue()
450 LockSupport.parkUntil(Long.MIN_VALUE); in parkUntilWithUnderflowValue()
468 LockSupport.parkNanos(nanos); in LongParker()
476 LockSupport.unpark(parkerThread); in quit()
DOldThreadTest.java23 import java.util.concurrent.locks.LockSupport;
110 LockSupport.park(); in test_joinWithSpuriousInterruption()
120 LockSupport.unpark(parker); in test_joinWithSpuriousInterruption()
/libcore/ojluni/annotations/mmodule/java/lang/
DThread.annotated.java33 import java.util.concurrent.locks.LockSupport;
/libcore/ojluni/annotations/sdk/nullability/java/lang/
DThread.annotated.java33 import java.util.concurrent.locks.LockSupport;
/libcore/ojluni/src/main/java/java/lang/
DThread.java40 import java.util.concurrent.locks.LockSupport;
/libcore/
Dopenjdk_java_files.bp1054 "ojluni/src/main/java/java/util/concurrent/locks/LockSupport.java",
DEXPECTED_UPSTREAM1105 …a/util/concurrent/locks/LockSupport.java,jdk17u/jdk-17.0.6-ga,src/java.base/share/classes/java/uti…

12