Home
last modified time | relevance | path

Searched defs:lock (Results 1 – 25 of 37) sorted by relevance

12

/libcore/luni/src/main/java/java/util/concurrent/
DDelayQueue.java44 private final transient ReentrantLock lock = new ReentrantLock(); field in DelayQueue
108 final ReentrantLock lock = this.lock; in offer() local
155 final ReentrantLock lock = this.lock; in poll() local
176 final ReentrantLock lock = this.lock; in take() local
221 final ReentrantLock lock = this.lock; in poll() local
271 final ReentrantLock lock = this.lock; in peek() local
281 final ReentrantLock lock = this.lock; in size() local
312 final ReentrantLock lock = this.lock; in drainTo() local
362 final ReentrantLock lock = this.lock; in clear() local
395 final ReentrantLock lock = this.lock; in toArray() local
[all …]
DLinkedBlockingDeque.java126 final ReentrantLock lock = new ReentrantLock(); field in LinkedBlockingDeque
165 final ReentrantLock lock = this.lock; in LinkedBlockingDeque() local
312 final ReentrantLock lock = this.lock; in offerFirst() local
327 final ReentrantLock lock = this.lock; in offerLast() local
343 final ReentrantLock lock = this.lock; in putFirst() local
360 final ReentrantLock lock = this.lock; in putLast() local
379 final ReentrantLock lock = this.lock; in offerFirst() local
402 final ReentrantLock lock = this.lock; in offerLast() local
435 final ReentrantLock lock = this.lock; in pollFirst() local
445 final ReentrantLock lock = this.lock; in pollLast() local
[all …]
DArrayBlockingQueue.java80 final ReentrantLock lock; field in ArrayBlockingQueue
251 final ReentrantLock lock = this.lock; in ArrayBlockingQueue() local
296 final ReentrantLock lock = this.lock; in offer() local
319 final ReentrantLock lock = this.lock; in put() local
343 final ReentrantLock lock = this.lock; in offer() local
359 final ReentrantLock lock = this.lock; in poll() local
369 final ReentrantLock lock = this.lock; in take() local
382 final ReentrantLock lock = this.lock; in poll() local
397 final ReentrantLock lock = this.lock; in peek() local
414 final ReentrantLock lock = this.lock; in size() local
[all …]
DCyclicBarrier.java123 private final ReentrantLock lock = new ReentrantLock(); field in CyclicBarrier
168 final ReentrantLock lock = this.lock; in dowait() local
413 final ReentrantLock lock = this.lock; in isBroken() local
432 final ReentrantLock lock = this.lock; in reset() local
449 final ReentrantLock lock = this.lock; in getNumberWaiting() local
DPriorityBlockingQueue.java127 private final ReentrantLock lock; field in PriorityBlockingQueue
441 final ReentrantLock lock = this.lock; in offer() local
495 final ReentrantLock lock = this.lock; in poll() local
505 final ReentrantLock lock = this.lock; in take() local
519 final ReentrantLock lock = this.lock; in poll() local
532 final ReentrantLock lock = this.lock; in peek() local
555 final ReentrantLock lock = this.lock; in size() local
622 final ReentrantLock lock = this.lock; in remove() local
639 final ReentrantLock lock = this.lock; in removeEQ() local
663 final ReentrantLock lock = this.lock; in contains() local
[all …]
DScheduledThreadPoolExecutor.java805 private final ReentrantLock lock = new ReentrantLock(); field in ScheduledThreadPoolExecutor.DelayedWorkQueue
912 final ReentrantLock lock = this.lock; in contains() local
922 final ReentrantLock lock = this.lock; in remove() local
945 final ReentrantLock lock = this.lock; in size() local
963 final ReentrantLock lock = this.lock; in peek() local
976 final ReentrantLock lock = this.lock; in offer() local
1028 final ReentrantLock lock = this.lock; in poll() local
1042 final ReentrantLock lock = this.lock; in take() local
1078 final ReentrantLock lock = this.lock; in poll() local
1118 final ReentrantLock lock = this.lock; in clear() local
[all …]
/libcore/jsr166-tests/src/test/java/jsr166/
DReentrantReadWriteLockTest.java26 final ReentrantReadWriteLock lock; field in ReentrantReadWriteLockTest.InterruptibleLockRunnable
38 final ReentrantReadWriteLock lock; field in ReentrantReadWriteLockTest.InterruptedLockRunnable
65 void releaseWriteLock(PublicReentrantReadWriteLock lock) { in releaseWriteLock()
76 void waitForQueuedThread(PublicReentrantReadWriteLock lock, Thread t) { in waitForQueuedThread()
90 void assertNotWriteLocked(PublicReentrantReadWriteLock lock) { in assertNotWriteLocked()
102 void assertWriteLockedBy(PublicReentrantReadWriteLock lock, Thread t) { in assertWriteLockedBy()
119 void assertWriteLockedByMoi(PublicReentrantReadWriteLock lock) { in assertWriteLockedByMoi()
126 void assertHasNoWaiters(PublicReentrantReadWriteLock lock, Condition c) { in assertHasNoWaiters()
133 void assertHasWaiters(PublicReentrantReadWriteLock lock, Condition c, in assertHasWaiters()
174 PublicReentrantReadWriteLock lock; in testConstructor() local
[all …]
DReentrantLockTest.java25 final ReentrantLock lock; field in ReentrantLockTest.InterruptibleLockRunnable
37 final ReentrantLock lock; field in ReentrantLockTest.InterruptedLockRunnable
64 void releaseLock(PublicReentrantLock lock) { in releaseLock()
74 void waitForQueuedThread(PublicReentrantLock lock, Thread t) { in waitForQueuedThread()
88 void assertNotLocked(PublicReentrantLock lock) { in assertNotLocked()
98 void assertLockedBy(PublicReentrantLock lock, Thread t) { in assertLockedBy()
110 void assertLockedByMoi(PublicReentrantLock lock) { in assertLockedByMoi()
117 void assertHasNoWaiters(PublicReentrantLock lock, Condition c) { in assertHasNoWaiters()
124 void assertHasWaiters(PublicReentrantLock lock, Condition c, in assertHasWaiters()
166 PublicReentrantLock lock; in testConstructor() local
[all …]
DForkJoinPoolTest.java89 final ReentrantLock lock; field in ForkJoinPoolTest.ManagedLocker
91 ManagedLocker(ReentrantLock lock) { this.lock = lock; } in ManagedLocker()
128 final ReentrantLock lock; field in ForkJoinPoolTest.LockingFibTask
129 LockingFibTask(int n, ManagedLocker locker, ReentrantLock lock) { in LockingFibTask()
356 ReentrantLock lock = new ReentrantLock(); in testBlockingForkJoinTask() local
DSemaphoreTest.java40 final Semaphore lock; field in SemaphoreTest.InterruptibleLockRunnable
54 final Semaphore lock; field in SemaphoreTest.InterruptedLockRunnable
311 final PublicSemaphore lock = new PublicSemaphore(1, fair); in testHasQueuedThreads() local
334 final PublicSemaphore lock = new PublicSemaphore(1, fair); in testGetQueueLength() local
357 final PublicSemaphore lock = new PublicSemaphore(1, fair); in testGetQueuedThreads() local
/libcore/luni/src/main/native/
DAsynchronousCloseMonitor.cpp66 ScopedPthreadMutexLock lock(&blockedThreadListMutex); in signalBlockedThreads() local
81 ScopedPthreadMutexLock lock(&blockedThreadListMutex); in AsynchronousCloseMonitor() local
96 ScopedPthreadMutexLock lock(&blockedThreadListMutex); in ~AsynchronousCloseMonitor() local
/libcore/luni/src/main/java/java/io/
DReader.java43 protected Object lock; field in Reader
62 protected Reader(Object lock) { in Reader()
DWriter.java41 protected Object lock; field in Writer
60 protected Writer(Object lock) { in Writer()
/libcore/luni/src/main/java/java/util/concurrent/locks/
DReentrantLock.java94 abstract void lock(); in lock() method in ReentrantLock.Sync
176 final void lock() { in lock() method in ReentrantLock.NonfairSync
194 final void lock() { in lock() method in ReentrantLock.FairSync
255 public void lock() { in lock() method in ReentrantLock
DLock.java155 void lock(); in lock() method
DReentrantReadWriteLock.java684 protected ReadLock(ReentrantReadWriteLock lock) { in ReadLock()
698 public void lock() { in lock() method in ReentrantReadWriteLock.ReadLock
893 protected WriteLock(ReentrantReadWriteLock lock) { in WriteLock()
914 public void lock() { in lock() method in ReentrantReadWriteLock.WriteLock
/libcore/luni/src/test/java/libcore/java/lang/
DOldAndroidMonitorTest.java295 private static void deepWait(int depth, Object lock) { in deepWait()
313 Object lock; field in OldAndroidMonitorTest.Worker
316 Worker(int id, Object lock) { in Worker()
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/
DWriterTest.java68 Object lock = new Object(); in test_writeLjava_lang_String() local
77 MockLockWriter(Object lock) { in MockLockWriter()
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/
DFileLockTest.java105 FileLock lock = new MockFileLock(null, 0, 10, true); in test_channel() local
141 FileLock lock = new MockFileLock(null, 0, 10, true); in test_isShared() local
DFileChannelLockingTest.java189 FileLock lock = readOnlyChannel.tryLock(10, 788, true); in test_tryLockLLZ() local
/libcore/luni/src/main/java/java/util/
DTimerTask.java29 final Object lock = new Object(); field in TimerTask
/libcore/luni/src/main/java/java/nio/
DFileChannelImpl.java159 public final FileLock lock(long position, long size, boolean shared) throws IOException { in lock() method in FileChannelImpl
188 public void release(FileLock lock) throws IOException { in release()
544 private synchronized void addLock(FileLock lock) throws OverlappingFileLockException { in addLock()
563 private synchronized void removeLock(FileLock lock) { in removeLock()
/libcore/luni/src/main/java/java/nio/channels/
DFileChannel.java184 public final FileLock lock() throws IOException { in lock() method in FileChannel
250 public abstract FileLock lock(long position, long size, boolean shared) in lock() method in FileChannel
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/
DThreadTest.java425 final Object lock = new Object(); in test_getThreadGroup() local
453 final Object lock = new Object(); in test_interrupt() local
655 final Object lock = new Object(); in test_joinJ() local
708 final Object lock = new Object(); in test_joinJI() local
/libcore/libart/src/main/java/java/lang/
DThread.java185 private final Object lock = new Object(); field in Thread
1026 Object lock = currentThread().lock; in sleep() local
1048 private static native void sleep(Object lock, long millis, int nanos); in sleep()

12