- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 19 for readLock (0.05 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
private ReentrantLock lockA; private ReentrantLock lockB; private ReentrantLock lockC; private ReentrantReadWriteLock.ReadLock readLockA; private ReentrantReadWriteLock.ReadLock readLockB; private ReentrantReadWriteLock.ReadLock readLockC; private ReentrantReadWriteLock.WriteLock writeLockA; private ReentrantReadWriteLock.WriteLock writeLockB; private ReentrantReadWriteLock.WriteLock writeLockC;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 16.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
private ReentrantLock lockA; private ReentrantLock lockB; private ReentrantLock lockC; private ReentrantReadWriteLock.ReadLock readLockA; private ReentrantReadWriteLock.ReadLock readLockB; private ReentrantReadWriteLock.ReadLock readLockC; private ReentrantReadWriteLock.WriteLock writeLockA; private ReentrantReadWriteLock.WriteLock writeLockB; private ReentrantReadWriteLock.WriteLock writeLockC;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 16.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
super(fair); this.readLock = new CycleDetectingReentrantReadLock(this); this.writeLock = new CycleDetectingReentrantWriteLock(this); this.lockGraphNode = Preconditions.checkNotNull(lockGraphNode); } ///// Overridden ReentrantReadWriteLock methods. ///// @Override public ReadLock readLock() { return readLock; } @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 36K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Striped.java
private final ReadWriteLock delegate; WeakSafeReadWriteLock() { this.delegate = new ReentrantReadWriteLock(); } @Override public Lock readLock() { return new WeakSafeLock(delegate.readLock(), this); } @Override public Lock writeLock() { return new WeakSafeLock(delegate.writeLock(), this); } }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 16 22:01:32 GMT 2025 - 20.6K bytes - Click Count (0) -
internal/dsync/drwmutex.go
defer dm.m.Unlock() // Check if minimally a single bool is set in the writeLocks array lockFound := slices.ContainsFunc(dm.readLocks, isLocked) if !lockFound { panic("Trying to RUnlock() while no RLock() is active") } // Copy write locks to stack array copy(locks, dm.readLocks) } // Tolerance is not set, defaults to half of the locker clients. tolerance := len(restClnts) / 2 isReadLock := true
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.3K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java
* * @return list of child file info */ public List<FileInfo> getChildren() { lock.readLock().lock(); try { lastAccessTime = System.currentTimeMillis(); return new ArrayList<>(children.values()); } finally { lock.readLock().unlock(); } } /** * Get a specific child * * @param name child nameCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 02:21:31 GMT 2025 - 11.4K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/persistent/PersistentHandleManager.java
* @return the handle info or null if not found */ public HandleInfo getHandleByGuid(HandleGuid guid) { lock.readLock().lock(); try { return guidToHandle.get(guid); } finally { lock.readLock().unlock(); } } /** * Get handle information by path * @param path the file pathCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:49:49 GMT 2025 - 13K bytes - Click Count (0) -
docs/smb3-features/04-directory-leasing-design.md
public List<FileInfo> getChildren() { lock.readLock().lock(); try { lastAccessTime = System.currentTimeMillis(); return new ArrayList<>(children.values()); } finally { lock.readLock().unlock(); } } public FileInfo getChild(String name) { lock.readLock().lock(); try {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 36.2K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java
mojos.put(Thread.currentThread(), mojoDescriptor); boolean aggregator = mojoDescriptor.isAggregator(); acquiredAggregatorLock = aggregator ? aggregatorLock.writeLock() : aggregatorLock.readLock(); acquiredProjectLock = getProjectLock(session); if (!acquiredAggregatorLock.tryLock()) { Thread owner = aggregatorLock.getOwner();
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Jun 12 14:55:55 GMT 2025 - 21K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/Smb2SigningDigestTest.java
} assertTrue(hasNonZero, "Each array should have a signature"); } } @Test @DisplayName("Should handle high concurrency without deadlock") void testHighConcurrencyNoDeadlock() throws InterruptedException { int threadCount = 100; int operationsPerThread = 50;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 43.7K bytes - Click Count (0)