- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for readLocks (0.68 sec)
-
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
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
ReentrantReadWriteLock readWriteLockC = factory.newReentrantReadWriteLock("ReadWriteC"); readLockA = readWriteLockA.readLock(); readLockB = readWriteLockB.readLock(); readLockC = readWriteLockC.readLock(); writeLockA = readWriteLockA.writeLock(); writeLockB = readWriteLockB.writeLock(); writeLockC = readWriteLockC.writeLock();
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 16.2K bytes - Viewed (0) -
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
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 17:06:34 UTC 2025 - 35.9K bytes - Viewed (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
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 17:06:34 UTC 2025 - 35.9K bytes - Viewed (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 nameRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 02:21:31 UTC 2025 - 11.4K bytes - Viewed (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 pathRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 24 00:49:49 UTC 2025 - 13K bytes - Viewed (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 {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 36.2K bytes - Viewed (0) -
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); } }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 16 22:01:32 UTC 2025 - 20.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
} /** * Using this as the blocker object allows introspection and debugging tools to see that the * currentRunner thread is blocked on the progress of the interruptor thread, which can help * identify deadlocks. */ @VisibleForTesting static final class Blocker extends AbstractOwnableSynchronizer implements Runnable { private final InterruptibleTask<?> task; private Blocker(InterruptibleTask<?> task) {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 10K bytes - Viewed (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();
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Jun 12 14:55:55 UTC 2025 - 21K bytes - Viewed (0)