Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 161 for queues (0.08 seconds)

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

     * a regular priority queue, the methods {@link #peekLast}, {@link #pollLast} and {@link
     * #removeLast} are also provided, to act on the <i>greatest</i> element in the queue instead.
     *
     * <p>A min-max priority queue can be configured with a maximum size. If so, each time the size of
     * the queue exceeds that value, the queue automatically removes its greatest element according to
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 13:11:08 GMT 2026
    - 34K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

     * a regular priority queue, the methods {@link #peekLast}, {@link #pollLast} and {@link
     * #removeLast} are also provided, to act on the <i>greatest</i> element in the queue instead.
     *
     * <p>A min-max priority queue can be configured with a maximum size. If so, each time the size of
     * the queue exceeds that value, the queue automatically removes its greatest element according to
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 13:11:08 GMT 2026
    - 34K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/cache/LocalCache.java

         * fraction of read operations.
         */
        final AtomicInteger readCount = new AtomicInteger();
    
        /**
         * A queue of elements currently in the map, ordered by write time. Elements are added to the
         * tail of the queue on write.
         */
        @GuardedBy("this")
        final Queue<ReferenceEntry<K, V>> writeQueue;
    
        /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 143.5K bytes
    - Click Count (0)
  4. guava/src/com/google/common/collect/MapMakerInternalMap.java

        WeakValueReferenceImpl(ReferenceQueue<V> queue, V referent, E entry) {
          super(referent, queue);
          this.entry = entry;
        }
    
        @Override
        public E getEntry() {
          return entry;
        }
    
        @Override
        public WeakValueReference<K, V, E> copyFor(ReferenceQueue<V> queue, E entry) {
          return new WeakValueReferenceImpl<>(queue, get(), entry);
        }
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 89.9K bytes
    - Click Count (0)
  5. guava/src/com/google/common/cache/LocalCache.java

         * fraction of read operations.
         */
        final AtomicInteger readCount = new AtomicInteger();
    
        /**
         * A queue of elements currently in the map, ordered by write time. Elements are added to the
         * tail of the queue on write.
         */
        @GuardedBy("this")
        final Queue<ReferenceEntry<K, V>> writeQueue;
    
        /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 148.9K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

        WeakValueReferenceImpl(ReferenceQueue<V> queue, V referent, E entry) {
          super(referent, queue);
          this.entry = entry;
        }
    
        @Override
        public E getEntry() {
          return entry;
        }
    
        @Override
        public WeakValueReference<K, V, E> copyFor(ReferenceQueue<V> queue, E entry) {
          return new WeakValueReferenceImpl<>(queue, get(), entry);
        }
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 89.9K bytes
    - Click Count (0)
  7. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

    /**
     * A bounded {@linkplain BlockingQueue blocking queue} backed by an array. This queue orders
     * elements FIFO (first-in-first-out). The head of the queue is that element that has been
     * on the queue the longest time. The tail of the queue is that element that has been on
     * the queue the shortest time. New elements are inserted at the tail of the queue, and the queue
     * retrieval operations obtain elements at the head of the queue.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 22.4K bytes
    - Click Count (0)
  8. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

    /**
     * A bounded {@linkplain BlockingQueue blocking queue} backed by an array. This queue orders
     * elements FIFO (first-in-first-out). The head of the queue is that element that has been
     * on the queue the longest time. The tail of the queue is that element that has been on
     * the queue the shortest time. New elements are inserted at the tail of the queue, and the queue
     * retrieval operations obtain elements at the head of the queue.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 22.4K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java

        assertFalse(segment.clearValueForTesting(key, hash, valueRef));
        segment.setWeakValueReferenceForTesting(entry, valueRef);
        assertTrue(segment.clearValueForTesting(key, hash, valueRef));
      }
    
      // reference queues
    
      public void testDrainKeyReferenceQueueOnWrite() {
        for (MapMaker maker : allWeakKeyStrengthMakers()) {
          MapMakerInternalMap<Object, Object, ?, ?> map = makeMap(maker.concurrencyLevel(1));
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 36K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java

        assertFalse(segment.clearValueForTesting(key, hash, valueRef));
        segment.setWeakValueReferenceForTesting(entry, valueRef);
        assertTrue(segment.clearValueForTesting(key, hash, valueRef));
      }
    
      // reference queues
    
      public void testDrainKeyReferenceQueueOnWrite() {
        for (MapMaker maker : allWeakKeyStrengthMakers()) {
          MapMakerInternalMap<Object, Object, ?, ?> map = makeMap(maker.concurrencyLevel(1));
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 36K bytes
    - Click Count (0)
Back to Top