Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for writeWork (0.12 sec)

  1. internal/dsync/dsync-server_test.go

    		subrouter.Methods(http.MethodPost).Path("/v1/force-unlock").HandlerFunc(lockServer.ForceUnlockHandler)
    
    		nodes[i] = httptest.NewServer(router)
    	}
    }
    
    const WriteLock = -1
    
    type lockServer struct {
    	mutex sync.Mutex
    	// Map of locks, with negative value indicating (exclusive) write lock
    	// and positive values indicating number of read locks
    	lockMap map[string]int64
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 23 16:46:37 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

      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;
      private ReentrantLock lock3;
      private ReentrantLock lock01;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

      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;
      private ReentrantLock lock3;
      private ReentrantLock lock01;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        Lock readLock = striped.get(key).readLock();
        WeakReference<Object> garbage = new WeakReference<>(new Object());
        GcFinalization.awaitClear(garbage);
        Lock writeLock = striped.get(key).writeLock();
        readLock.lock();
        assertFalse(writeLock.tryLock());
        readLock.unlock();
      }
    
      @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts.
      public void testStrongImplementations() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        Lock readLock = striped.get(key).readLock();
        WeakReference<Object> garbage = new WeakReference<>(new Object());
        GcFinalization.awaitClear(garbage);
        Lock writeLock = striped.get(key).writeLock();
        readLock.lock();
        assertFalse(writeLock.tryLock());
        readLock.unlock();
      }
    
      @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts.
      public void testStrongImplementations() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

          this.writeLock = new CycleDetectingReentrantWriteLock(this);
          this.lockGraphNode = Preconditions.checkNotNull(lockGraphNode);
        }
    
        ///// Overridden ReentrantReadWriteLock methods. /////
    
        @Override
        public ReadLock readLock() {
          return readLock;
        }
    
        @Override
        public WriteLock writeLock() {
          return writeLock;
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 35.9K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/Striped.java

        }
    
        @Override
        public Lock readLock() {
          return new WeakSafeLock(delegate.readLock(), this);
        }
    
        @Override
        public Lock writeLock() {
          return new WeakSafeLock(delegate.writeLock(), this);
        }
      }
    
      /** Lock object that ensures a strong reference is retained to a specified object. */
      private static final class WeakSafeLock extends ForwardingLock {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 20.6K bytes
    - Viewed (0)
Back to top