Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for mute (0.16 sec)

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

        inner.mutex = outer;
        outer.add("foo"); // necessary because we try to remove elements later on
        return outer;
      }
    
      private static final class TestQueue<E> implements Queue<E> {
        private final Queue<E> delegate = Lists.newLinkedList();
        public Object mutex;
    
        @Override
        public boolean offer(E o) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.offer(o);
        }
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Apr 19 19:24:36 GMT 2023
    - 4.7K bytes
    - Viewed (0)
  2. 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)
  3. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

      private Object mutex() {
        Object mutex = mutexDoNotUseDirectly;
        if (mutex == null) {
          synchronized (this) {
            mutex = mutexDoNotUseDirectly;
            if (mutex == null) {
              mutexDoNotUseDirectly = mutex = new Object();
            }
          }
        }
        return mutex;
      }
    
      RateLimiter(SleepingStopwatch stopwatch) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 18.2K bytes
    - Viewed (0)
  4. 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.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 53.4K bytes
    - Viewed (0)
  5. 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;
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Apr 19 19:24:36 GMT 2023
    - 12.2K 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));
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Apr 19 19:24:36 GMT 2023
    - 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 Integer(1); // 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
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Mon Mar 04 16:54:11 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  8. android/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;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 19 19:24:36 GMT 2023
    - 12.2K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/collect/SynchronizedSetTest.java

        final Set<E> delegate;
        public Object mutex;
    
        public TestSet(Set<E> delegate, @Nullable Object 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
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Mon Apr 17 11:19:47 GMT 2023
    - 4.7K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/collect/SynchronizedBiMapTest.java

        public TestBiMap(BiMap<K, V> delegate, Object mutex) {
          super(delegate, mutex);
          this.delegate = delegate;
        }
    
        @Override
        public @Nullable V forcePut(K key, V value) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.forcePut(key, value);
        }
    
        @Override
        public BiMap<V, K> inverse() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.inverse();
        }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 19 19:24:36 GMT 2023
    - 5.4K bytes
    - Viewed (0)
Back to top