/openjdk7/jdk/src/share/classes/java/util/concurrent/ |
H A D | PriorityBlockingQueue.java | 104 * operations protected with a single lock. However, allocation 106 * holding main lock) in order to allow takes to operate 109 * build-up. The need to back away from lock during allocation 111 * java.util.PriorityQueue operations within a lock, as was done 155 private final ReentrantLock lock; field in class:PriorityBlockingQueue 212 this.lock = new ReentrantLock(); 213 this.notEmpty = lock.newCondition(); 235 this.lock = new ReentrantLock(); 236 this.notEmpty = lock.newCondition(); 272 * holding lock [all...] |
H A D | CopyOnWriteArrayList.java | 82 /** The lock protecting all mutators */ 83 transient final ReentrantLock lock = new ReentrantLock(); field in class:CopyOnWriteArrayList 387 final ReentrantLock lock = this.lock; 388 lock.lock(); 404 lock.unlock(); 415 final ReentrantLock lock = this.lock; 416 lock [all...] |
H A D | LinkedBlockingDeque.java | 80 * single lock and using conditions to manage blocking. 154 /** Main lock guarding all access */ 155 final ReentrantLock lock = new ReentrantLock(); field in class:LinkedBlockingDeque 158 private final Condition notEmpty = lock.newCondition(); 161 private final Condition notFull = lock.newCondition(); 194 final ReentrantLock lock = this.lock; 195 lock.lock(); // Never contended, but necessary for visibility 204 lock [all...] |
/openjdk7/jdk/src/share/classes/java/util/concurrent/locks/ |
H A D | ReentrantLock.java | 43 * behavior and semantics as the implicit monitor lock accessed using 49 * {@code lock} will return, successfully acquiring the lock, when 50 * the lock is not owned by another thread. The method will return 51 * immediately if the current thread already owns the lock. This can 58 * thread. Otherwise this lock does not guarantee any particular 65 * fair lock may obtain it multiple times in succession while other 67 * lock. 69 * honor the fairness setting. It will succeed if the lock 73 * follow a call to {@code lock} wit 126 abstract void lock(); method in class:ReentrantLock.Sync 210 final void lock() { method in class:ReentrantLock.NonfairSync 228 final void lock() { method in class:ReentrantLock.FairSync 289 public void lock() { method in class:ReentrantLock [all...] |
H A D | ReentrantReadWriteLock.java | 50 * ordering for lock access. However, it does support an optional 56 * to the read and write lock is unspecified, subject to reentrancy 57 * constraints. A nonfair lock that is continuously contended may 59 * will normally have higher throughput than a fair lock. 64 * approximately arrival-order policy. When the currently held lock 66 * be assigned the write lock, or if there is a group of reader threads 68 * assigned the read lock. 70 * <p>A thread that tries to acquire a fair read lock (non-reentrantly) 71 * will block if either the write lock is held, or there is a waiting 72 * writer thread. The thread will not acquire the read lock unti 716 ReadLock(ReentrantReadWriteLock lock) argument 730 public void lock() { method in class:ReentrantReadWriteLock.ReadLock 923 WriteLock(ReentrantReadWriteLock lock) argument 944 public void lock() { method in class:ReentrantReadWriteLock.WriteLock [all...] |
/openjdk7/hotspot/src/share/vm/gc_implementation/g1/ |
H A D | dirtyCardQueue.cpp | 100 Mutex* lock, PtrQueueSet* fl_owner) { 104 _shared_dirty_card_queue.set_lock(lock); 97 initialize(Monitor* cbl_mon, Mutex* fl_lock, int process_completed_threshold, int max_completed_queue, Mutex* lock, PtrQueueSet* fl_owner) argument
|
H A D | satbQueue.cpp | 124 "we should have taken the lock before calling this"); 207 Mutex* lock) { 209 _shared_satb_queue.set_lock(lock); 205 initialize(Monitor* cbl_mon, Mutex* fl_lock, int process_completed_threshold, Mutex* lock) argument
|
/openjdk7/jdk/src/share/classes/com/sun/jmx/mbeanserver/ |
H A D | Repository.java | 99 * We use a global reentrant read write lock to protect the repository. 104 private final ReentrantReadWriteLock lock; field in class:Repository 326 lock = new ReentrantReadWriteLock(fairLock); 346 lock.readLock().lock(); 361 lock.readLock().unlock(); 376 * lock, when it has determined that the {@code object} 416 lock.writeLock().lock(); 445 lock [all...] |
/openjdk7/hotspot/src/share/vm/c1/ |
H A D | c1_ValueStack.cpp | 162 int ValueStack::lock(Value obj) { function in class:ValueStack 215 tty->print("lock %2d ", i);
|
/openjdk7/jdk/src/macosx/native/sun/awt/ |
H A D | ImageSurfaceData.h | 111 pthread_mutex_t lock; member in struct:_ImageSDOps
|
/openjdk7/jdk/src/solaris/native/com/sun/management/ |
H A D | LinuxOperatingSystem.c | 221 static pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER; variable 239 pthread_mutex_lock(&lock); 289 pthread_mutex_unlock(&lock);
|
/openjdk7/jdk/src/windows/classes/sun/nio/ch/ |
H A D | FileDispatcherImpl.java | 99 int lock(FileDescriptor fd, boolean blocking, long pos, long size, method in class:FileDispatcherImpl
|
/openjdk7/jdk/src/share/demo/jvmti/heapViewer/ |
H A D | heapViewer.c | 55 jrawMonitorID lock; member in struct:__anon527 72 err = (*jvmti)->RawMonitorEnter(jvmti, gdata->lock); 82 err = (*jvmti)->RawMonitorExit(jvmti, gdata->lock); 265 err = (*jvmti)->CreateRawMonitor(jvmti, "agent lock", &(gdata->lock));
|
/openjdk7/jdk/src/share/demo/jvmti/minst/ |
H A D | minst.c | 86 jrawMonitorID lock; member in struct:__anon540 102 error = (*jvmti)->RawMonitorEnter(jvmti, gdata->lock); 112 error = (*jvmti)->RawMonitorExit(jvmti, gdata->lock); 456 error = (*jvmti)->CreateRawMonitor(jvmti, "agent data", &(gdata->lock));
|
/openjdk7/jdk/src/share/native/com/sun/media/sound/ |
H A D | PlatformMidi.h | 93 void* lock; member in struct:tag_MidiQueue 121 void MIDI_DestroyLock(void* lock); 123 /* Blocks until this lock can be gotten. 124 * Nop if lock is NULL */ 125 void MIDI_Lock(void* lock); 127 /* Releases this lock */ 128 void MIDI_Unlock(void* lock);
|
/openjdk7/jdk/src/share/native/sun/awt/splashscreen/ |
H A D | splashscreen_impl.h | 86 CRITICAL_SECTION lock; member in struct:Splash 94 pthread_mutex_t lock; member in struct:Splash 98 pthread_mutex_t lock; member in struct:Splash
|
/openjdk7/jdk/src/share/demo/jvmti/compiledMethodLoad/ |
H A D | compiledMethodLoad.c | 55 static jrawMonitorID lock; variable 192 err = (*jvmti)->RawMonitorEnter(jvmti, lock); 220 err = (*jvmti)->RawMonitorExit(jvmti, lock); 267 err = (*jvmti)->CreateRawMonitor(jvmti, "agent lock", &lock);
|
/openjdk7/jdk/src/share/classes/sun/net/www/ |
H A D | MessageHeader.java | 183 Object lock; field in class:MessageHeader.HeaderIterator 185 public HeaderIterator (String k, Object lock) { argument 187 this.lock = lock; 190 synchronized (lock) { 206 synchronized (lock) {
|
/openjdk7/jdk/src/share/classes/sun/nio/ch/ |
H A D | ServerSocketChannelImpl.java | 60 private final Object lock = new Object(); field in class:ServerSocketChannelImpl 63 // DO NOT invoke a blocking I/O operation while holding this lock! 203 synchronized (lock) { 224 synchronized (lock) {
|
/openjdk7/jdk/src/share/classes/sun/nio/cs/ |
H A D | StreamEncoder.java | 50 Object lock, 59 return new StreamEncoder(out, lock, Charset.forName(csn)); 65 Object lock, 68 return new StreamEncoder(out, lock, cs); 72 Object lock, 75 return new StreamEncoder(out, lock, enc); 102 synchronized (lock) { 117 synchronized (lock) { 139 synchronized (lock) { 146 synchronized (lock) { 49 forOutputStreamWriter(OutputStream out, Object lock, String charsetName) argument 64 forOutputStreamWriter(OutputStream out, Object lock, Charset cs) argument 71 forOutputStreamWriter(OutputStream out, Object lock, CharsetEncoder enc) argument 174 StreamEncoder(OutputStream out, Object lock, Charset cs) argument 181 StreamEncoder(OutputStream out, Object lock, CharsetEncoder enc) argument [all...] |
/openjdk7/jdk/src/solaris/classes/sun/awt/X11/ |
H A D | XSelection.java | 50 private static final Object lock = new Object(); field in class:XSelection 76 // The orders of the lock acquisition: 78 // lock -> awtLock. 96 // protected with 'lock' and awtLock. 198 synchronized (lock) { 272 synchronized (lock) {
|
/openjdk7/jdk/src/solaris/classes/sun/nio/ch/ |
H A D | FileDispatcherImpl.java | 87 int lock(FileDescriptor fd, boolean blocking, long pos, long size, method in class:FileDispatcherImpl
|
H A D | SctpServerChannelImpl.java | 59 private final Object lock = new Object(); field in class:SctpServerChannelImpl 62 * DO NOT invoke a blocking I/O operation while holding this lock! */ 97 synchronized (lock) { 140 synchronized (lock) { 208 synchronized (lock) {
|
/openjdk7/jdk/src/share/classes/java/security/ |
H A D | Signature.java | 908 // lock for mutex during provider selection 909 private final Object lock; field in class:Signature.Delegate 923 this.lock = null; // no lock needed 932 this.lock = new Object(); 991 synchronized (lock) { 1041 synchronized (lock) {
|
/openjdk7/jdk/src/share/classes/java/util/prefs/ |
H A D | AbstractPreferences.java | 178 * An object whose monitor is used to lock this node. This object 182 * holds a lock on a descendant of that node. 184 protected final Object lock = new Object(); field in class:AbstractPreferences 225 * obtains this preference node's lock, checks that the node 247 synchronized(lock) { 262 * the case. Then it obtains this preference node's lock, 281 synchronized(lock) { 299 * <p>This implementation obtains this preference node's lock, 310 synchronized(lock) { 323 * <p>This implementation obtains this preference node's lock, [all...] |