Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 94 for Mutex (0.03 sec)

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

      private Synchronized() {}
    
      static class SynchronizedObject implements Serializable {
        final Object delegate;
        final Object mutex;
    
        SynchronizedObject(Object delegate, @CheckForNull 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 57.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/Synchronized.java

      private Synchronized() {}
    
      static class SynchronizedObject implements Serializable {
        final Object delegate;
        final Object mutex;
    
        SynchronizedObject(Object delegate, @CheckForNull 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 53.4K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/collect/SynchronizedNavigableMapTest.java

        TestMap<K, V> inner = new TestMap<>(innermost, mutex);
        NavigableMap<K, V> outer = Synchronized.navigableMap(inner, mutex);
        return outer;
      }
    
      static class TestEntry<K, V> extends ForwardingMapEntry<K, V> implements Serializable {
        private final Entry<K, V> delegate;
        private final Object mutex;
    
        TestEntry(Entry<K, V> delegate, Object mutex) {
          this.delegate = delegate;
          this.mutex = mutex;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jul 24 22:09:38 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  4. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Aug 19 20:50:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  6. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/collect/SynchronizedTableTest.java

        final Table<R, C, V> delegate = HashBasedTable.create();
        public 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  9. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/collect/SynchronizedTableTest.java

        final Table<R, C, V> delegate = HashBasedTable.create();
        public 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 4.6K bytes
    - Viewed (0)
Back to top