Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for WriteLock (4.34 sec)

  1. 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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 16.1K bytes
    - Viewed (0)
  2. 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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 16.1K bytes
    - Viewed (0)
  3. src/internal/poll/fd_unix.go

    					continue
    				}
    			}
    		}
    		err = fd.eofError(n, err)
    		return n, oobn, sysflags, err
    	}
    }
    
    // Write implements io.Writer.
    func (fd *FD) Write(p []byte) (int, error) {
    	if err := fd.writeLock(); err != nil {
    		return 0, err
    	}
    	defer fd.writeUnlock()
    	if err := fd.pd.prepareWrite(fd.isFile); err != nil {
    		return 0, err
    	}
    	var nn int
    	for {
    		max := len(p)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 04:09:44 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  4. android/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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 35.9K bytes
    - Viewed (0)
  5. src/internal/poll/fd_windows.go

    	if err != nil {
    		return n, err
    	}
    	rawToSockaddrInet6(o.rsa, sa6)
    	return n, err
    }
    
    // Write implements io.Writer.
    func (fd *FD) Write(buf []byte) (int, error) {
    	if err := fd.writeLock(); err != nil {
    		return 0, err
    	}
    	defer fd.writeUnlock()
    	if fd.isFile {
    		fd.l.Lock()
    		defer fd.l.Unlock()
    	}
    
    	ntotal := 0
    	for len(buf) > 0 {
    		b := buf
    		if len(b) > maxRW {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 31 16:50:42 UTC 2024
    - 34.1K 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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 35.9K bytes
    - Viewed (0)
  7. platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/adapter/ProtocolToModelAdapter.java

                lock.readLock().lock();
                Optional<Method> cached = store.get(key);
                if (cached == null) {
                    cacheMiss++;
                    lock.readLock().unlock();
                    lock.writeLock().lock();
                    try {
                        cached = store.get(key);
                        if (cached == null) {
                            cached = lookup(owner, name, parameterTypes);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 21 04:42:54 UTC 2024
    - 45.4K bytes
    - Viewed (0)
  8. src/os/file_plan9.go

    // It returns the number of bytes written and an error, if any.
    // Since Plan 9 preserves message boundaries, never allow
    // a zero-byte write.
    func (f *File) write(b []byte) (n int, err error) {
    	if err := f.writeLock(); err != nil {
    		return 0, err
    	}
    	defer f.writeUnlock()
    	if len(b) == 0 {
    		return 0, nil
    	}
    	return fixCount(syscall.Write(f.fd, b))
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 30 15:35:30 UTC 2024
    - 16K bytes
    - Viewed (0)
  9. android/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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 10 20:55:18 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  10. 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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 10 20:55:18 UTC 2023
    - 20.3K bytes
    - Viewed (0)
Back to top