Searched refs:locks (Results 1 – 25 of 125) sorted by relevance
12345
23 import java.util.concurrent.locks.Lock;24 import java.util.concurrent.locks.ReentrantLock;76 private void lockAndUnlockNested(Lock[] locks, int reps) { in lockAndUnlockNested() argument78 for (int j = 0; j < locks.length; j++) { in lockAndUnlockNested()79 locks[j].lock(); in lockAndUnlockNested()81 for (int j = locks.length - 1; j >= 0; j--) { in lockAndUnlockNested()82 locks[j].unlock(); in lockAndUnlockNested()
35 import java.util.concurrent.locks.Lock;36 import java.util.concurrent.locks.ReentrantLock;94 final List<Lock> locks = new ArrayList<Lock>(numStripes); field in StripedBenchmark97 locks.clear(); in sizeOfPopulatedStriped()100 locks.add(striped.getAt(i)); in sizeOfPopulatedStriped()
40 import java.util.concurrent.locks.Lock;41 import java.util.concurrent.locks.ReadWriteLock;42 import java.util.concurrent.locks.ReentrantLock;43 import java.util.concurrent.locks.ReentrantReadWriteLock;342 final AtomicReferenceArray<ArrayReference<? extends L>> locks;350 this.locks = new AtomicReferenceArray<ArrayReference<? extends L>>(size);358 ArrayReference<? extends L> existingRef = locks.get(index);365 while (!locks.compareAndSet(index, existingRef, newRef)) {367 existingRef = locks.get(index);387 locks.compareAndSet(arrayRef.index, arrayRef, null);[all …]
137 Set<Integer> locks; field in StructuredLockingTest.LockFrame141 locks = new HashSet<Integer>(); in LockFrame()150 locks = new HashSet<Integer>(((LockFrame) src).locks); in init()172 locks.add(Integer.valueOf(lock))); in enter()177 locks.remove(Integer.valueOf(lock))); in exit()183 this.locks.addAll(((LockFrame) frame).locks); in merge()188 assertEquals(message, Collections.emptySet(), locks); in assertNoLock()
165 set<uptr> locks; in RunRemoveNodeTest() local166 locks.insert(l0); in RunRemoveNodeTest()167 locks.insert(l1); in RunRemoveNodeTest()168 locks.insert(l2); in RunRemoveNodeTest()169 locks.insert(l3); in RunRemoveNodeTest()170 locks.insert(l4); in RunRemoveNodeTest()171 locks.insert(l5); in RunRemoveNodeTest()174 locks.insert(lt); in RunRemoveNodeTest()179 EXPECT_EQ(locks.size(), d.size()); in RunRemoveNodeTest()195 locks.clear(); in RunRemoveNodeTest()[all …]
12 pthread_rwlock_t locks[LOCKS]; in main() local17 if ((e = pthread_rwlock_init(locks + n, NULL)) != 0) { in main()24 if ((e = pthread_rwlock_destroy(locks + n)) != 0) { in main()
38 import java.util.concurrent.locks.Lock;39 import java.util.concurrent.locks.ReadWriteLock;40 import java.util.concurrent.locks.ReentrantLock;41 import java.util.concurrent.locks.ReentrantReadWriteLock;151 Iterable<?> locks = striped.bulkGet(objects); in testBulkGetReturnsSorted() local152 assertTrue(Ordering.natural().onResultOf(Functions.forMap(indexByLock)).isOrdered(locks)); in testBulkGetReturnsSorted()156 assertEquals(Lists.newArrayList(locks), Lists.newArrayList(locks2)); in testBulkGetReturnsSorted()
349 DBusRMutex ***locks = data; in shutdown_global_locks() local355 if (*(locks[i]) != NULL) in shutdown_global_locks()356 _dbus_platform_rmutex_free (*(locks[i])); in shutdown_global_locks()358 *(locks[i]) = NULL; in shutdown_global_locks()362 dbus_free (locks); in shutdown_global_locks()
13 monitor info locks17 monitor info locks
20 import java.util.concurrent.locks.ReadWriteLock;21 import java.util.concurrent.locks.ReentrantReadWriteLock;
74 static Lock locks[SPINLOCK_COUNT] = { [0 ... SPINLOCK_COUNT-1] = {0,1,0} }; variable87 static Lock locks[SPINLOCK_COUNT]; // initialized to OS_SPINLOCK_INIT which is 0 variable104 static Lock locks[SPINLOCK_COUNT]; variable122 return locks + (hash & SPINLOCK_MASK); in lock_for_pointer()
22 import java.util.concurrent.locks.ReadWriteLock;23 import java.util.concurrent.locks.ReentrantReadWriteLock;
14 * xmlMutex are a simple mutual exception locks.18 * xmlRMutex are reentrant mutual exception locks.
36 import java.util.concurrent.locks.Lock;37 import java.util.concurrent.locks.ReentrantLock;
40 import java.util.concurrent.locks.Lock;41 import java.util.concurrent.locks.ReentrantLock;
39 import java.util.concurrent.locks.Lock;40 import java.util.concurrent.locks.ReentrantLock;
18 import java.util.concurrent.locks.Lock;19 import java.util.concurrent.locks.ReentrantLock;
22 import java.util.concurrent.locks.Lock;23 import java.util.concurrent.locks.ReentrantLock;
20 import java.util.concurrent.locks.Lock;21 import java.util.concurrent.locks.ReentrantLock;
... enable kernel lock metering, which adds overhead to SMP locks, 14+ but allows you to see various statistics ...
11 Thread #x: Exiting thread still holds 2 locks
12 Thread #x: Exiting thread still holds 2 locks
39 import java.util.concurrent.locks.ReadWriteLock;40 import java.util.concurrent.locks.ReentrantReadWriteLock;
60 * Use read/write locks over global locks.