mute - Code Search

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

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Apr 19 19:24:36 GMT 2023

- 7.4K bytes

- Viewed (0)

github.com/google/guava

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

    assertSame(MUTEX, ((SynchronizedNavigableSet<String>) descendingSet).mutex);
  }

  public void testHeadSet_E() {
    NavigableSet<String> map = create();
    SortedSet<String> headSet = map.headSet("a");
    assertTrue(headSet instanceof SynchronizedSortedSet);
    assertSame(MUTEX, ((SynchronizedSortedSet<String>) headSet).mutex);
  }

  public void testHeadSet_E_B() {

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Apr 19 19:24:36 GMT 2023

- 7.7K bytes

- Viewed (0)

github.com/google/guava

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

      return super.equals(o);
    }

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

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

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

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Wed May 09 15:17:25 GMT 2018

- 8.5K bytes

- Viewed (0)

github.com/google/guava

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

    NavigableSet<E> outer = Synchronized.navigableSet(inner, null);
    inner.mutex = outer;
    return outer;
  }

  static class TestSet<E> extends SynchronizedSetTest.TestSet<E> implements NavigableSet<E> {

    TestSet(NavigableSet<E> delegate, @Nullable Object mutex) {
      super(delegate, mutex);
    }

    @Override
    protected NavigableSet<E> delegate() {

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Wed Apr 19 19:24:36 GMT 2023

- 7.7K bytes

- Viewed (0)

github.com/google/guava

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

      return super.equals(o);
    }

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

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

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

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Thu Apr 06 12:56:11 GMT 2023

- 8.5K 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));

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Wed Apr 19 19:24:36 GMT 2023

- 7.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/admin-heal-ops.go

	var count int64
	h.mutex.RLock()
	defer h.mutex.RUnlock()

	for _, v := range h.scannedItemsMap {
		count += v
	}
	return count
}

// getScannedItemsMap - returns map of all scanned items against type
func (h *healSequence) getScannedItemsMap() map[madmin.HealItemType]int64 {
	h.mutex.RLock()
	defer h.mutex.RUnlock()

	// Make a copy before returning the value

Go

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Thu Apr 04 12:04:40 GMT 2024

- 25.1K bytes

- Viewed (1)

github.com/google/guava

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

    final Set<E> delegate;
    public final Object mutex;

    public TestSet(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();
    }

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Mon Apr 17 11:19:47 GMT 2023

- 4.8K 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()
}

Go

- Registered: Sun Apr 21 19:28:08 GMT 2024

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

- 2.5K 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));

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Apr 19 19:24:36 GMT 2023

- 5.8K bytes

- Viewed (0)

Search Options