- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 13 for ReentrantReadWriteLock (0.17 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
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; private ReentrantLock lock1; private ReentrantLock lock2;
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 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; private ReentrantLock lock1; private ReentrantLock lock2;
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
import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import java.util.logging.Level; import org.jspecify.annotations.Nullable; /** * The {@code CycleDetectingLockFactory} creates {@link ReentrantLock} instances and {@link * ReentrantReadWriteLock} instances that detect potential deadlock by checking for cycles in lock * acquisition order. *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-tests/test/com/google/common/util/concurrent/StripedTest.java
.add(new Striped.SmallLazyStriped<ReadWriteLock>(50, ReentrantReadWriteLock::new)) .add(new Striped.SmallLazyStriped<ReadWriteLock>(64, ReentrantReadWriteLock::new)) .add(new Striped.LargeLazyStriped<ReadWriteLock>(50, ReentrantReadWriteLock::new)) .add(new Striped.LargeLazyStriped<ReadWriteLock>(64, ReentrantReadWriteLock::new)) .add(new Striped.SmallLazyStriped<Lock>(50, ReentrantLock::new))
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 8.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/StripedTest.java
.add(new Striped.SmallLazyStriped<ReadWriteLock>(50, ReentrantReadWriteLock::new)) .add(new Striped.SmallLazyStriped<ReadWriteLock>(64, ReentrantReadWriteLock::new)) .add(new Striped.LargeLazyStriped<ReadWriteLock>(50, ReentrantReadWriteLock::new)) .add(new Striped.LargeLazyStriped<ReadWriteLock>(64, ReentrantReadWriteLock::new)) .add(new Striped.SmallLazyStriped<Lock>(50, ReentrantLock::new))
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 8.1K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/persistent/PersistentHandleManager.java
private final Path stateDirectory; private final ScheduledExecutorService scheduler; private final CIFSContext context; private final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); private volatile boolean shutdown = false; /** * Create a new persistent handle manager * @param context the CIFS context */Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:49:49 GMT 2025 - 13K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java
import java.util.List; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantReadWriteLock; /** * Cache entry for directory contents with thread-safe operations */ public class DirectoryCacheEntry { private final String directoryPath; private final Smb2LeaseKey leaseKey;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 02:21:31 GMT 2025 - 11.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Striped.java
import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import org.jspecify.annotations.Nullable; /** * A striped {@code Lock/Semaphore/ReadWriteLock}. This offers the underlying lock striping similarCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 16 22:01:32 GMT 2025 - 20.6K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java
import java.util.Set; import java.util.TreeSet; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import org.apache.maven.api.SessionData; import org.apache.maven.api.services.MavenException; import org.apache.maven.api.services.MessageBuilderFactory; import org.apache.maven.artifact.Artifact;
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/main/java/jcifs/internal/smb2/lease/LeaseManager.java
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.CIFSContext; import jcifs.smb.SmbFile; /** * SMB2/SMB3 Lease Manager *
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 18.8K bytes - Click Count (0)