mutex - Code Search

guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

      return delegate.offer(o);
    }

    @Override
    public @Nullable E poll() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.poll();
    }

    @Override
    public E remove() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.remove();
    }

    @Override
    public boolean remove(Object object) {
      assertTrue(Thread.holdsLock(mutex));

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Wed Jul 16 17:42:14 UTC 2025

- 7.4K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

      return delegate.offer(o);
    }

    @Override
    public @Nullable E poll() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.poll();
    }

    @Override
    public E remove() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.remove();
    }

    @Override
    public boolean remove(Object object) {
      assertTrue(Thread.holdsLock(mutex));

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Wed Jul 16 17:42:14 UTC 2025

- 7.4K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/collect/SynchronizedMapTest.java

      checkNotNull(mutex);
      this.delegate = delegate;
      this.mutex = mutex;
    }

    @Override
    protected Map<K, V> delegate() {
      return delegate;
    }

    @Override
    public int size() {
      assertTrue(Thread.holdsLock(mutex));
      return super.size();
    }

    @Override
    public boolean isEmpty() {
      assertTrue(Thread.holdsLock(mutex));

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Mon Jul 28 19:11:14 UTC 2025

- 5.9K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/collect/SynchronizedTableTest.java

    private final Object mutex = new Object[0]; // something Serializable

    @Override
    public String toString() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.toString();
    }

    @Override
    public boolean equals(@Nullable Object o) {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.equals(o);
    }

    @Override

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Wed Jul 16 17:42:14 UTC 2025

- 4.7K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/LockHeldAssertingSet.java

  final Set<E> delegate;
  final Object mutex;

  LockHeldAssertingSet(Set<E> delegate, Object mutex) {
    checkNotNull(mutex);
    this.delegate = delegate;
    this.mutex = mutex;
  }

  @Override
  protected Set<E> delegate() {
    return delegate;
  }

  @Override
  public String toString() {
    assertTrue(Thread.holdsLock(mutex));
    return super.toString();
  }

  @Override

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Thu Feb 13 17:34:21 UTC 2025

- 4.3K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/SynchronizedMapTest.java

      checkNotNull(mutex);
      this.delegate = delegate;
      this.mutex = mutex;
    }

    @Override
    protected Map<K, V> delegate() {
      return delegate;
    }

    @Override
    public int size() {
      assertTrue(Thread.holdsLock(mutex));
      return super.size();
    }

    @Override
    public boolean isEmpty() {
      assertTrue(Thread.holdsLock(mutex));

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Fri Jul 18 14:47:20 UTC 2025

- 5.9K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/SynchronizedTableTest.java

    private final Object mutex = new Object[0]; // something Serializable

    @Override
    public String toString() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.toString();
    }

    @Override
    public boolean equals(@Nullable Object o) {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.equals(o);
    }

    @Override

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Wed Jul 16 17:42:14 UTC 2025

- 4.7K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java

      return delegate.offer(o);
    }

    @Override
    public @Nullable E poll() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.poll();
    }

    @Override
    public E remove() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.remove();
    }

    @Override
    public boolean remove(Object object) {
      assertTrue(Thread.holdsLock(mutex));

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Wed Jul 16 17:42:14 UTC 2025

- 4.8K bytes

- Viewed (0)

github.com/minio/minio

internal/dsync/dsync-server_test.go

		time.Sleep(time.Duration(d))
	}

	l.mutex.Lock()
	defer l.mutex.Unlock()
	reply = !l.lockNotFound
	return reply, nil
}

func (l *lockServer) ForceUnlock(args *LockArgs) (reply bool, err error) {
	if d := atomic.LoadInt64(&l.responseDelay); d != 0 {
		time.Sleep(time.Duration(d))
	}

	l.mutex.Lock()
	defer l.mutex.Unlock()
	if len(args.UID) != 0 {

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Fri Aug 29 02:39:48 UTC 2025

- 8.3K bytes

- Viewed (0)

github.com/minio/minio

internal/lock/lock.go

type RLockedFile struct {
	*LockedFile
	mutex sync.Mutex
	refs  int // Holds read lock refs.
}

// IsClosed - Check if the rlocked file is already closed.
func (r *RLockedFile) IsClosed() bool {
	r.mutex.Lock()
	defer r.mutex.Unlock()
	return r.refs == 0
}

// IncLockRef - is used by called to indicate lock refs.
func (r *RLockedFile) IncLockRef() {
	r.mutex.Lock()
	r.refs++
	r.mutex.Unlock()
}

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Jan 02 17:15:06 UTC 2022

- 2.5K bytes

- Viewed (0)

Search Options