Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 114 for queue (0.13 seconds)

  1. android/guava/src/com/google/common/collect/Queues.java

       *
       * @param queue the queue to be wrapped in a synchronized view
       * @return a synchronized view of the specified queue
       * @since 14.0
       */
      @J2ktIncompatible // Synchronized
      public static <E extends @Nullable Object> Queue<E> synchronizedQueue(Queue<E> queue) {
        return Synchronized.queue(queue, null);
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 18.2K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/Queues.java

       *
       * @param queue the queue to be wrapped in a synchronized view
       * @return a synchronized view of the specified queue
       * @since 14.0
       */
      @J2ktIncompatible // Synchronized
      public static <E extends @Nullable Object> Queue<E> synchronizedQueue(Queue<E> queue) {
        return Synchronized.queue(queue, null);
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 18K bytes
    - Click Count (0)
  3. 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)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

        /**
         * QueueHolder holds the waiting and crawling queues.
         */
        protected static class QueueHolder {
            /**
             * Constructs a new QueueHolder.
             */
            public QueueHolder() {
                // Default constructor
            }
    
            /**
             * The queue for URLs waiting to be crawled.
             */
            protected Queue<OpenSearchUrlQueue> waitingQueue = new ConcurrentLinkedQueue<>();
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Nov 20 08:40:57 GMT 2025
    - 16.9K bytes
    - Click Count (1)
  5. guava/src/com/google/common/collect/MinMaxPriorityQueue.java

     * defined as the <i>least</i> element in the queue according to the queue's comparator. But unlike
     * 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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 13:11:08 GMT 2026
    - 34K bytes
    - Click Count (0)
  6. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

       * formally, removes an element {@code e} such that {@code o.equals(e)}, if this queue contains
       * one or more such elements. Returns {@code true} if and only if this queue contained the
       * specified element (or equivalently, if this queue changed as a result of the call).
       *
       * @param o element to be removed from this queue, if present
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 19K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/collect/EvictingQueueTest.java

        assertTrue(queue.add("one"));
        assertTrue(queue.add("two"));
        assertTrue(queue.add("three"));
        assertThat(queue.element()).isEqualTo("one");
        assertThat(queue.peek()).isEqualTo("one");
        assertEquals(3, queue.size());
        assertEquals(0, queue.remainingCapacity());
    
        assertTrue(queue.add("four"));
        assertThat(queue.element()).isEqualTo("two");
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java

        assertEquals(6, queue.size());
        assertEquals(8, queue.capacity());
        checkUnbounded(queue);
        checkNatural(queue);
      }
    
      public void testCreation_maximumSize_withContents() {
        MinMaxPriorityQueue<Integer> queue =
            rawtypeToWildcard(MinMaxPriorityQueue.maximumSize(42)).create(NUMBERS);
        assertEquals(6, queue.size());
        assertEquals(11, queue.capacity());
        assertEquals(42, queue.maximumSize);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 13:11:08 GMT 2026
    - 36.2K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        private final BlockingQueue<String> queue;
    
        EnableWrites(BlockingQueue<String> queue, long tMinus) {
          super(tMinus);
          assertFalse(queue.isEmpty());
          assertFalse(queue.offer("shouldBeRejected"));
          this.queue = queue;
        }
    
        @Override
        protected void doAction() {
          assertThat(queue.remove()).isNotNull();
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 38.1K bytes
    - Click Count (0)
  10. 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)
Back to Top