| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | ArrayBlockingQueue.java | 75 final ReentrantLock lock; field in ArrayBlockingQueue
198 lock = new ReentrantLock(fair); in ArrayBlockingQueue()
199 notEmpty = lock.newCondition(); in ArrayBlockingQueue()
200 notFull = lock.newCondition(); in ArrayBlockingQueue()
223 final ReentrantLock lock = this.lock; in ArrayBlockingQueue() local
224 lock.lock(); // Lock only for visibility, not mutual exclusion in ArrayBlockingQueue()
238 lock.unlock(); in ArrayBlockingQueue()
268 final ReentrantLock lock = this.lock; in offer() local
269 lock.lock(); in offer()
278 lock.unlock(); in offer()
[all …]
|
| D | DelayQueue.java | 42 private transient final ReentrantLock lock = new ReentrantLock(); field in DelayQueue
68 private final Condition available = lock.newCondition();
106 final ReentrantLock lock = this.lock; in offer() local
107 lock.lock(); in offer()
116 lock.unlock(); in offer()
153 final ReentrantLock lock = this.lock; in poll() local
154 lock.lock(); in poll()
162 lock.unlock(); in poll()
174 final ReentrantLock lock = this.lock; in take() local
175 lock.lockInterruptibly(); in take()
[all …]
|
| D | LinkedBlockingDeque.java | 126 final ReentrantLock lock = new ReentrantLock(); field in LinkedBlockingDeque
129 private final Condition notEmpty = lock.newCondition();
132 private final Condition notFull = lock.newCondition();
165 final ReentrantLock lock = this.lock; in LinkedBlockingDeque() local
166 lock.lock(); // Never contended, but necessary for visibility in LinkedBlockingDeque()
175 lock.unlock(); in LinkedBlockingDeque()
312 final ReentrantLock lock = this.lock; in offerFirst() local
313 lock.lock(); in offerFirst()
317 lock.unlock(); in offerFirst()
327 final ReentrantLock lock = this.lock; in offerLast() local
[all …]
|
| D | CyclicBarrier.java | 120 private final ReentrantLock lock = new ReentrantLock(); field in CyclicBarrier
122 private final Condition trip = lock.newCondition();
165 final ReentrantLock lock = this.lock; in dowait() local
166 lock.lock(); in dowait()
225 lock.unlock(); in dowait()
410 final ReentrantLock lock = this.lock; in isBroken() local
411 lock.lock(); in isBroken()
415 lock.unlock(); in isBroken()
429 final ReentrantLock lock = this.lock; in reset() local
430 lock.lock(); in reset()
[all …]
|
| D | PriorityBlockingQueue.java | 125 private final ReentrantLock lock; field in PriorityBlockingQueue
182 this.lock = new ReentrantLock(); in PriorityBlockingQueue()
183 this.notEmpty = lock.newCondition(); in PriorityBlockingQueue()
205 this.lock = new ReentrantLock(); in PriorityBlockingQueue()
206 this.notEmpty = lock.newCondition(); in PriorityBlockingQueue()
248 lock.unlock(); // must release and then re-acquire main lock in tryGrow()
271 lock.lock(); in tryGrow()
436 final ReentrantLock lock = this.lock; in offer() local
437 lock.lock(); in offer()
451 lock.unlock(); in offer()
[all …]
|
| D | ScheduledThreadPoolExecutor.java | 808 private final ReentrantLock lock = new ReentrantLock(); field in ScheduledThreadPoolExecutor.DelayedWorkQueue
833 private final Condition available = lock.newCondition();
915 final ReentrantLock lock = this.lock; in contains() local
916 lock.lock(); in contains()
920 lock.unlock(); in contains()
925 final ReentrantLock lock = this.lock; in remove() local
926 lock.lock(); in remove()
943 lock.unlock(); in remove()
948 final ReentrantLock lock = this.lock; in size() local
949 lock.lock(); in size()
[all …]
|
| /libcore/luni/src/main/java/java/io/ |
| D | FilterReader.java | 56 synchronized (lock) { in close()
79 synchronized (lock) { in mark()
96 synchronized (lock) { in markSupported()
113 synchronized (lock) { in read()
138 synchronized (lock) { in read()
156 synchronized (lock) { in ready()
176 synchronized (lock) { in reset()
196 synchronized (lock) { in skip()
|
| D | Reader.java | 43 protected Object lock; field in Reader
50 lock = this; in Reader()
62 protected Reader(Object lock) { in Reader() argument
63 if (lock == null) { in Reader()
66 this.lock = lock; in Reader()
123 synchronized (lock) { in read()
220 synchronized (lock) { in skip()
|
| D | Writer.java | 41 protected Object lock; field in Writer
48 lock = this; in Writer()
60 protected Writer(Object lock) { in Writer() argument
61 if (lock == null) { in Writer()
64 this.lock = lock; in Writer()
125 synchronized (lock) { in write()
166 synchronized (lock) { in write()
|
| D | CharArrayWriter.java | 49 lock = buf; in CharArrayWriter()
67 lock = buf; in CharArrayWriter()
104 synchronized (lock) { in reset()
117 synchronized (lock) { in size()
130 synchronized (lock) { in toCharArray()
146 synchronized (lock) { in toString()
168 synchronized (lock) { in write()
185 synchronized (lock) { in write()
210 synchronized (lock) { in write()
230 synchronized (lock) { in writeTo()
|
| D | LineNumberReader.java | 68 synchronized (lock) { in getLineNumber()
91 synchronized (lock) { in mark()
116 synchronized (lock) { in read()
158 synchronized (lock) { in read()
194 synchronized (lock) { in readLine()
221 synchronized (lock) { in reset()
239 synchronized (lock) { in setLineNumber()
265 synchronized (lock) { in skip()
|
| D | FilterWriter.java | 57 synchronized (lock) { in close()
71 synchronized (lock) { in flush()
91 synchronized (lock) { in write()
107 synchronized (lock) { in write()
128 synchronized (lock) { in write()
|
| D | CharArrayReader.java | 102 synchronized (lock) {
140 synchronized (lock) {
177 synchronized (lock) {
211 synchronized (lock) {
237 synchronized (lock) {
254 synchronized (lock) {
271 synchronized (lock) {
|
| D | StringReader.java | 89 synchronized (lock) { in mark()
124 synchronized (lock) { in read()
156 synchronized (lock) { in read()
185 synchronized (lock) { in ready()
204 synchronized (lock) { in reset()
232 synchronized (lock) { in skip()
|
| D | PushbackReader.java | 85 synchronized (lock) { in close()
137 synchronized (lock) { in read()
184 synchronized (lock) { in read()
231 synchronized (lock) { in ready()
305 synchronized (lock) { in unread()
332 synchronized (lock) { in unread()
356 synchronized (lock) { in skip()
|
| D | BufferedReader.java | 110 synchronized (lock) { in close()
195 synchronized (lock) { in mark()
235 synchronized (lock) { in read()
273 synchronized (lock) { in read()
351 synchronized (lock) { in readLine()
439 synchronized (lock) { in ready()
457 synchronized (lock) { in reset()
489 synchronized (lock) { in skip()
|
| D | PrintWriter.java | 220 synchronized (lock) { in clearError()
231 synchronized (lock) { in close()
250 synchronized (lock) { in flush()
471 synchronized (lock) { in println()
548 synchronized (lock) { in println()
566 synchronized (lock) { in setError()
620 synchronized (lock) { in doWrite()
|
| /libcore/luni/src/main/java/java/util/ |
| D | TimerTask.java | 29 final Object lock = new Object(); field in TimerTask
51 synchronized (lock) { in getWhen()
60 synchronized (lock) { in setScheduledTime()
72 synchronized (lock) { in isScheduled()
92 synchronized (lock) { in cancel()
107 synchronized (lock) { in scheduledExecutionTime()
|
| /libcore/support/src/test/java/tests/support/ |
| D | Support_StringWriter.java | 34 lock = buf; in Support_StringWriter()
45 lock = buf; in Support_StringWriter()
79 synchronized (lock) { in getBuffer()
93 synchronized (lock) { in toString()
117 synchronized (lock) { in write()
136 synchronized (lock) { in write()
151 synchronized (lock) { in write()
174 synchronized (lock) { in write()
|
| D | Support_StringReader.java | 54 synchronized (lock) { in close()
82 synchronized (lock) { in mark()
119 synchronized (lock) { in read()
152 synchronized (lock) { in read()
187 synchronized (lock) { in ready()
206 synchronized (lock) { in reset()
229 synchronized (lock) { in skip()
|
| /libcore/luni/src/test/java/libcore/java/lang/ |
| D | OldAndroidMonitorTest.java | 295 private static void deepWait(int depth, Object lock) { in deepWait() argument
296 synchronized (lock) { in deepWait()
298 deepWait(depth - 1, lock); in deepWait()
303 lock.wait(); in deepWait()
313 Object lock; field in OldAndroidMonitorTest.Worker
316 Worker(int id, Object lock) { in Worker() argument
319 this.lock = lock; in Worker()
326 OldAndroidMonitorTest.deepWait(id, lock); in run()
362 synchronized (w[j].lock) { in testNestedMonitors()
363 w[j].lock.notify(); in testNestedMonitors()
[all …]
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| D | OldDatagramPacketTest.java | 40 final Object lock = new Object(); in test_getPort() local
47 synchronized (lock) { in test_getPort()
49 lock.notifyAll(); in test_getPort()
72 synchronized (lock) { in test_getPort()
75 lock.wait(); in test_getPort()
|
| /libcore/luni/src/main/native/ |
| D | AsynchronousSocketCloseMonitor.cpp | 61 ScopedPthreadMutexLock lock(&blockedThreadListMutex); in signalBlockedThreads() local
71 ScopedPthreadMutexLock lock(&blockedThreadListMutex); in AsynchronousSocketCloseMonitor() local
85 ScopedPthreadMutexLock lock(&blockedThreadListMutex); in ~AsynchronousSocketCloseMonitor() local
|
| /libcore/luni/src/main/java/java/util/prefs/ |
| D | AbstractPreferences.java | 97 protected final Object lock; field in AbstractPreferences
156 lock = new Object(); in AbstractPreferences()
191 synchronized (lock) { in getChild()
214 synchronized (lock) { in isRemoved()
352 synchronized (lock) { in childrenNames()
365 synchronized (lock) { in clear()
392 synchronized (lock) { in flush()
408 synchronized (lock) { in get()
513 synchronized (lock) { in keys()
527 synchronized (lock) { in node()
[all …]
|
| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| D | ReentrantLock.java | 97 abstract void lock(); in lock() method in ReentrantLock.Sync
181 final void lock() { in lock() method in ReentrantLock.NonfairSync
199 final void lock() { in lock() method in ReentrantLock.FairSync
260 public void lock() { in lock() method in ReentrantLock
261 sync.lock(); in lock()
|