mutex - Code Search

guava/src/com/google/common/collect/Synchronized.java

  private Synchronized() {}

  private static class SynchronizedObject implements Serializable {
    final Object delegate;
    final Object mutex;

    SynchronizedObject(Object delegate, @Nullable Object mutex) {
      this.delegate = checkNotNull(delegate);
      this.mutex = (mutex == null) ? this : mutex;
    }

    Object delegate() {
      return delegate;
    }

    // No equals and hashCode; see ForwardingObject for details.

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

- Last Modified: Fri Aug 08 15:11:10 UTC 2025

- 56.9K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/collect/Synchronized.java

  private Synchronized() {}

  private static class SynchronizedObject implements Serializable {
    final Object delegate;
    final Object mutex;

    SynchronizedObject(Object delegate, @Nullable Object mutex) {
      this.delegate = checkNotNull(delegate);
      this.mutex = (mutex == null) ? this : mutex;
    }

    Object delegate() {
      return delegate;
    }

    // No equals and hashCode; see ForwardingObject for details.

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

- Last Modified: Fri Aug 08 15:11:10 UTC 2025

- 53K bytes

- Viewed (0)

github.com/google/guava

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/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)

Search Options