Home
last modified time | relevance | path

Searched refs:ReentrantLock (Results 1 – 25 of 29) sorted by relevance

12

/libcore/ojluni/src/main/java/java/util/concurrent/
DDelayQueue.java47 import java.util.concurrent.locks.ReentrantLock;
80 private final transient ReentrantLock lock = new ReentrantLock();
144 final ReentrantLock lock = this.lock; in offer()
191 final ReentrantLock lock = this.lock; in poll()
211 final ReentrantLock lock = this.lock; in take()
256 final ReentrantLock lock = this.lock; in poll()
306 final ReentrantLock lock = this.lock; in peek()
316 final ReentrantLock lock = this.lock; in size()
347 final ReentrantLock lock = this.lock; in drainTo()
372 final ReentrantLock lock = this.lock; in clear()
[all …]
DCyclicBarrier.java39 import java.util.concurrent.locks.ReentrantLock;
159 private final ReentrantLock lock = new ReentrantLock();
204 final ReentrantLock lock = this.lock; in dowait()
449 final ReentrantLock lock = this.lock; in isBroken()
468 final ReentrantLock lock = this.lock; in reset()
485 final ReentrantLock lock = this.lock; in getNumberWaiting()
DLinkedBlockingDeque.java46 import java.util.concurrent.locks.ReentrantLock;
159 final ReentrantLock lock = new ReentrantLock();
337 final ReentrantLock lock = this.lock; in offerFirst()
352 final ReentrantLock lock = this.lock; in offerLast()
368 final ReentrantLock lock = this.lock; in putFirst()
385 final ReentrantLock lock = this.lock; in putLast()
404 final ReentrantLock lock = this.lock; in offerFirst()
427 final ReentrantLock lock = this.lock; in offerLast()
460 final ReentrantLock lock = this.lock; in pollFirst()
470 final ReentrantLock lock = this.lock; in pollLast()
[all …]
DArrayBlockingQueue.java48 import java.util.concurrent.locks.ReentrantLock;
121 final ReentrantLock lock;
274 lock = new ReentrantLock(fair); in ArrayBlockingQueue()
299 final ReentrantLock lock = this.lock; in ArrayBlockingQueue()
343 final ReentrantLock lock = this.lock; in offer()
366 final ReentrantLock lock = this.lock; in put()
390 final ReentrantLock lock = this.lock; in offer()
406 final ReentrantLock lock = this.lock; in poll()
416 final ReentrantLock lock = this.lock; in take()
429 final ReentrantLock lock = this.lock; in poll()
[all …]
DPriorityBlockingQueue.java52 import java.util.concurrent.locks.ReentrantLock;
164 private final ReentrantLock lock = new ReentrantLock();
469 final ReentrantLock lock = this.lock; in offer()
523 final ReentrantLock lock = this.lock; in poll()
533 final ReentrantLock lock = this.lock; in take()
547 final ReentrantLock lock = this.lock; in poll()
560 final ReentrantLock lock = this.lock; in peek()
583 final ReentrantLock lock = this.lock; in size()
649 final ReentrantLock lock = this.lock; in remove()
668 final ReentrantLock lock = this.lock; in removeEq()
[all …]
DScheduledThreadPoolExecutor.java50 import java.util.concurrent.locks.ReentrantLock;
934 private final ReentrantLock lock = new ReentrantLock();
1041 final ReentrantLock lock = this.lock; in contains()
1051 final ReentrantLock lock = this.lock; in remove()
1074 final ReentrantLock lock = this.lock; in size()
1092 final ReentrantLock lock = this.lock; in peek()
1105 final ReentrantLock lock = this.lock; in offer()
1157 final ReentrantLock lock = this.lock; in poll()
1170 final ReentrantLock lock = this.lock; in take()
1206 final ReentrantLock lock = this.lock; in poll()
[all …]
DThreadPoolExecutor.java47 import java.util.concurrent.locks.ReentrantLock;
474 private final ReentrantLock mainLock = new ReentrantLock();
729 final ReentrantLock mainLock = this.mainLock; in tryTerminate()
801 final ReentrantLock mainLock = this.mainLock; in interruptIdleWorkers()
932 final ReentrantLock mainLock = this.mainLock; in addWorker()
973 final ReentrantLock mainLock = this.mainLock; in addWorkerFailed()
1002 final ReentrantLock mainLock = this.mainLock; in processWorkerExit()
1388 final ReentrantLock mainLock = this.mainLock; in shutdown()
1419 final ReentrantLock mainLock = this.mainLock; in shutdownNow()
1465 final ReentrantLock mainLock = this.mainLock; in awaitTermination()
[all …]
DLinkedBlockingQueue.java47 import java.util.concurrent.locks.ReentrantLock;
156 private final ReentrantLock takeLock = new ReentrantLock();
163 private final ReentrantLock putLock = new ReentrantLock();
174 final ReentrantLock takeLock = this.takeLock; in signalNotEmpty()
187 final ReentrantLock putLock = this.putLock; in signalNotFull()
273 final ReentrantLock putLock = this.putLock; in LinkedBlockingQueue()
330 final ReentrantLock putLock = this.putLock; in put()
371 final ReentrantLock putLock = this.putLock; in offer()
410 final ReentrantLock putLock = this.putLock; in offer()
431 final ReentrantLock takeLock = this.takeLock; in take()
[all …]
DSubmissionPublisher.java44 import java.util.concurrent.locks.ReentrantLock;
239 final ReentrantLock lock;
280 this.lock = new ReentrantLock(); in SubmissionPublisher()
344 ReentrantLock lock = this.lock; in subscribe()
401 ReentrantLock lock = this.lock; in doOffer()
624 ReentrantLock lock = this.lock; in close()
660 ReentrantLock lock = this.lock; in closeExceptionally()
711 ReentrantLock lock = this.lock; in hasSubscribers()
738 ReentrantLock lock = this.lock; in getNumberOfSubscribers()
775 ReentrantLock lock = this.lock; in getSubscribers()
[all …]
DSynchronousQueue.java49 import java.util.concurrent.locks.ReentrantLock;
1122 private ReentrantLock qlock;
1135 qlock = new ReentrantLock(true); in writeObject()
1140 qlock = new ReentrantLock(); in writeObject()
DForkJoinPool.java54 import java.util.concurrent.locks.ReentrantLock;
1419 final ReentrantLock registrationLock;
1495 ReentrantLock lock = registrationLock;
1548 ReentrantLock lock = registrationLock;
2153 int md = mode, n, i; WorkQueue q; ReentrantLock lock;
2343 ReentrantLock lock; Condition cond; // signal when no workers
2546 this.registrationLock = new ReentrantLock();
2600 this.registrationLock = new ReentrantLock();
3278 ReentrantLock lock; Condition cond;
/libcore/jsr166-tests/src/test/java/jsr166/
DReentrantLockTest.java19 import java.util.concurrent.locks.ReentrantLock;
40 final ReentrantLock lock;
41 InterruptibleLockRunnable(ReentrantLock lock) { this.lock = lock; } in InterruptibleLockRunnable()
52 final ReentrantLock lock;
53 InterruptedLockRunnable(ReentrantLock lock) { this.lock = lock; } in InterruptedLockRunnable()
62 static class PublicReentrantLock extends ReentrantLock {
217 ReentrantLock lock = new ReentrantLock(fair); in testUnlock_IMSE()
296 final ReentrantLock lock = new ReentrantLock(fair); in testHasQueuedThreadNPE()
426 ReentrantLock lock = new ReentrantLock(fair); in testGetHoldCount()
444 final ReentrantLock lock = new ReentrantLock(fair); in testIsLocked()
[all …]
DForkJoinPoolTest.java29 import java.util.concurrent.locks.ReentrantLock;
99 final ReentrantLock lock;
101 ManagedLocker(ReentrantLock lock) { this.lock = lock; } in ManagedLocker()
138 final ReentrantLock lock;
139 LockingFibTask(int n, ManagedLocker locker, ReentrantLock lock) { in LockingFibTask()
373 ReentrantLock lock = new ReentrantLock();
DThreadPoolExecutorSubclassTest.java37 import java.util.concurrent.locks.ReentrantLock;
55 final ReentrantLock lock = new ReentrantLock();
/libcore/ojluni/src/test/java/util/concurrent/tck/
DReentrantLockTest.java45 import java.util.concurrent.locks.ReentrantLock;
63 final ReentrantLock lock;
64 InterruptibleLockRunnable(ReentrantLock lock) { this.lock = lock; } in InterruptibleLockRunnable()
75 final ReentrantLock lock;
76 InterruptedLockRunnable(ReentrantLock lock) { this.lock = lock; } in InterruptedLockRunnable()
85 static class PublicReentrantLock extends ReentrantLock {
240 final ReentrantLock lock = new ReentrantLock(fair); in testUnlock_IMSE()
319 final ReentrantLock lock = new ReentrantLock(fair); in testHasQueuedThreadNPE()
449 final ReentrantLock lock = new ReentrantLock(fair); in testGetHoldCount()
466 final ReentrantLock lock = new ReentrantLock(fair); in testIsLocked()
[all …]
DForkJoinPoolTest.java56 import java.util.concurrent.locks.ReentrantLock;
117 final ReentrantLock lock;
119 ManagedLocker(ReentrantLock lock) { this.lock = lock; } in ManagedLocker()
156 final ReentrantLock lock;
157 LockingFibTask(int n, ManagedLocker locker, ReentrantLock lock) { in LockingFibTask()
391 ReentrantLock lock = new ReentrantLock();
DThreadPoolExecutorSubclassTest.java62 import java.util.concurrent.locks.ReentrantLock;
77 final ReentrantLock lock = new ReentrantLock();
/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/locks/
DReentrantLock.java41 public class ReentrantLock implements java.util.concurrent.locks.Lock, java.io.Serializable { class
43 public ReentrantLock() { in ReentrantLock() method in ReentrantLock
47 public ReentrantLock(boolean fair) { in ReentrantLock() method in ReentrantLock
132 private final java.util.concurrent.locks.ReentrantLock.Sync sync;
139 static final class FairSync extends java.util.concurrent.locks.ReentrantLock.Sync {
157 static final class NonfairSync extends java.util.concurrent.locks.ReentrantLock.Sync {
/libcore/ojluni/src/main/java/java/util/concurrent/locks/
DReentrantLock.java108 public class ReentrantLock implements Lock, java.io.Serializable { class
293 public ReentrantLock() { in ReentrantLock() method in ReentrantLock
303 public ReentrantLock(boolean fair) { in ReentrantLock() method in ReentrantLock
/libcore/ojluni/src/main/java/java/net/
DInMemoryCookieStore.java37 import java.util.concurrent.locks.ReentrantLock;
69 private ReentrantLock lock = null;
83 lock = new ReentrantLock(false); in InMemoryCookieStore()
/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/
DLinkedBlockingQueue.java204 private final java.util.concurrent.locks.ReentrantLock putLock;
213 private final java.util.concurrent.locks.ReentrantLock takeLock;
DPriorityBlockingQueue.java218 private final java.util.concurrent.locks.ReentrantLock lock;
DLinkedBlockingDeque.java293 final java.util.concurrent.locks.ReentrantLock lock;
DThreadPoolExecutor.java365 private final java.util.concurrent.locks.ReentrantLock mainLock;
/libcore/luni/src/test/java/libcore/java/lang/
DThreadTest.java36 import java.util.concurrent.locks.ReentrantLock;
505 final ReentrantLock lock = new ReentrantLock(); in threadDoubleStart()

12