Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 476 for lockR (0.02 seconds)

  1. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/util/ports/ReservedPortRange.java

    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Random;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    public class ReservedPortRange {
        private final int startPort;
        private final int endPort;
        private final Lock lock = new ReentrantLock();
        private PortDetector portDetector = new DefaultPortDetector();
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 2.8K bytes
    - Click Count (0)
  2. kotlin-js-store/yarn.lock

    Yuri Schimke <******@****.***> 1690028931 +0100
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Jul 22 12:28:51 GMT 2023
    - 87.4K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * method equivalent to {@link
     * java.util.concurrent.locks.ReentrantLock#hasWaiters(java.util.concurrent.locks.Condition)},
     * except that the method parameter must accept whatever condition-like object is passed into {@code
     * callAndAssertWaits} by the test.
     *
     * @param <L> the type of the lock-like object to be used
     * @author Justin T. Sampson
     */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * method equivalent to {@link
     * java.util.concurrent.locks.ReentrantLock#hasWaiters(java.util.concurrent.locks.Condition)},
     * except that the method parameter must accept whatever condition-like object is passed into {@code
     * callAndAssertWaits} by the test.
     *
     * @param <L> the type of the lock-like object to be used
     * @author Justin T. Sampson
     */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/smb1/com/SmbComLockingAndXTest.java

            setField(cmd, "timeout", 3000L);
            // arrays of one lock and one unlock range
            LockingAndXRange lock = new LockingAndXRange(false);
            lock.encode(new byte[20], 0); // initialise fields by encoding to set pid etc (though not needed)
            setField(lock, "pid", 123);
            setField(lock, "byteOffset", 100L);
            setField(lock, "lengthInBytes", 200L);
            LockingAndXRange unlock = new LockingAndXRange(false);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  6. docs/contribute/concurrency.md

    ### Locks
    
    We have 3 different things that we synchronize on.
    
    #### Http2Connection
    
    This lock guards internal state of each connection. This lock is never held for blocking operations. That means that we acquire the lock, read or write a few fields and release the lock. No I/O and no application-layer callbacks.
    
    #### Http2Stream
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 16:35:36 GMT 2022
    - 7K bytes
    - Click Count (0)
  7. cmd/local-locker.go

    	Source          string // Contains line, function and filename requesting the lock.
    	Group           bool   // indicates if it was a group lock.
    	Owner           string // Owner represents the UUID of the owner who originally requested the lock.
    	Quorum          int    // Quorum represents the quorum required for this lock to be active.
    	idx             int    `msg:"-"` // index of the lock in the lockMap.
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
  8. src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java

                }
            } finally {
                lock.writeLock().unlock();
            }
        }
    
        /**
         * Remove a child entry
         *
         * @param childName child file name
         */
        public void removeChild(String childName) {
            lock.writeLock().lock();
            try {
                if (children.remove(childName) != null) {
    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)
  9. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java

    import java.util.List;
    import java.util.Map;
    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;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Thu Jun 12 14:55:55 GMT 2025
    - 21K bytes
    - Click Count (0)
  10. src/main/java/jcifs/internal/smb2/lock/Smb2LockResponse.java

     */
    package jcifs.internal.smb2.lock;
    
    import jcifs.Configuration;
    import jcifs.internal.SMBProtocolDecodingException;
    import jcifs.internal.smb2.ServerMessageBlock2Response;
    import jcifs.internal.util.SMBUtil;
    
    /**
     * SMB2 Lock response message. This response acknowledges the successful
     * acquisition or release of byte-range locks.
     *
     * @author mbechler
     *
     */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2.1K bytes
    - Click Count (0)
Back to Top