Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 426 for locks (0.01 sec)

  1. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

       *
       * Lock lockA = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockB = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockC = factory2.newReentrantLock(MyLockOrder.FIRST);
       *
       * lockA.lock();
       *
       * lockB.lock();  // will throw an IllegalStateException
       * lockC.lock();  // will throw an IllegalStateException
       *
       * lockA.lock();  // reentrant acquisition is okay
       * }
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 18 15:05:43 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        checkMessage(expected, "LockC -> LockA", "LockB -> LockC", "LockA -> LockB");
      }
    
      public void testReentrancy_noDeadlock() {
        lockA.lock();
        lockB.lock();
        lockA.lock(); // Should not assert on lockB -> reentrant(lockA)
      }
    
      public void testExplicitOrdering_noViolations() {
        lock1.lock();
        lock3.lock();
        lock3.unlock();
        lock2.lock();
        lock3.lock();
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        checkMessage(expected, "LockC -> LockA", "LockB -> LockC", "LockA -> LockB");
      }
    
      public void testReentrancy_noDeadlock() {
        lockA.lock();
        lockB.lock();
        lockA.lock(); // Should not assert on lockB -> reentrant(lockA)
      }
    
      public void testExplicitOrdering_noViolations() {
        lock1.lock();
        lock3.lock();
        lock3.unlock();
        lock2.lock();
        lock3.lock();
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.Semaphore;
    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 junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for Striped.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.Semaphore;
    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 junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for Striped.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  6. src/test/java/jcifs/internal/smb2/lock/Smb2LockRequestTest.java

                // Verify total bytes written (structure + lock data)
                assertEquals(24 + 24, bytesWritten); // 24 for structure, 24 for lock
            }
    
            @Test
            @DisplayName("Should write request structure correctly with multiple locks")
            void testWriteBytesWireFormatMultipleLocks() {
                Smb2Lock[] locks = new Smb2Lock[] { new Smb2Lock(0L, 100L, Smb2Lock.SMB2_LOCKFLAG_EXCLUSIVE_LOCK),
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  7. cmd/local-locker_test.go

    	rng := rand.New(rand.NewSource(0))
    	quorum := 0
    	// Numbers of unique locks
    	for _, locks := range []int{100, 1000, 1e6} {
    		if testing.Short() && locks > 100 {
    			continue
    		}
    		t.Run(fmt.Sprintf("%d-locks", locks), func(t *testing.T) {
    			// Number of readers per lock...
    			for _, readers := range []int{1, 10, 100} {
    				if locks > 1000 && readers > 1 {
    					continue
    				}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb1/com/SmbComLockingAndX.java

                bufferIndex += this.unlocks[i].decode(buffer, bufferIndex, buffer.length);
            }
    
            for (int i = 0; i < this.locks.length; i++) {
                this.locks[i] = createLockRange();
                bufferIndex += this.locks[i].decode(buffer, bufferIndex, buffer.length);
            }
    
            return start - bufferIndex;
        }
    
        /**
         * @return
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/lock/Smb2LockRequest.java

        private int lockSequenceIndex;
        private byte[] fileId;
        private final Smb2Lock[] locks;
    
        /**
         * Constructs an SMB2 lock request with the specified parameters.
         *
         * @param config the configuration for this request
         * @param fileId the file identifier for the file to lock
         * @param locks the array of lock elements to apply
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  10. android/guava-tests/benchmark/com/google/common/util/concurrent/StripedBenchmark.java

        return impl.get(numStripes);
      }
    
      // a place to put the locks in sizeOfPopulatedStriped so they don't get GC'd before we measure
      final List<Lock> locks = new ArrayList<>(numStripes);
    
      @Footprint
      Object sizeOfPopulatedStriped() {
        locks.clear();
        Striped<Lock> striped = impl.get(numStripes);
        for (int i : stripes) {
          locks.add(striped.getAt(i));
        }
        return striped;
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 4K bytes
    - Viewed (0)
Back to top