Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 106 for Queue (0.04 sec)

  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);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  2. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

        delayNanos: Long,
      ) {
        lock.assertHeld()
    
        val queue = task.queue!!
        check(queue.activeTask === task)
    
        val cancelActiveTask = queue.cancelActiveTask
        queue.cancelActiveTask = false
        queue.activeTask = null
        busyQueues.remove(queue)
    
        if (delayNanos != -1L && !cancelActiveTask && !queue.shutdown) {
          queue.scheduleAndDecide(task, delayNanos, recurrence = true)
        }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  4. 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);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  5. 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);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  6. internal/event/config_test.go

            </S3Key>
       </Filter>
       <Queue>arn:minio:sqs:us-east-1:1:webhook</Queue>
       <Event>s3:ObjectCreated:Put</Event>
    </QueueConfiguration>`)
    	queue2 := &Queue{}
    	if err := xml.Unmarshal(data, queue2); err != nil {
    		panic(err)
    	}
    
    	data = []byte(`
    <QueueConfiguration>
       <Id>1</Id>
       <Filter></Filter>
       <Queue>arn:minio:sqs:eu-west-2:1:webhook</Queue>
       <Event>s3:ObjectAccessed:*</Event>
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 29K bytes
    - Viewed (0)
  7. 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);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  8. 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.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 19 19:24:36 UTC 2023
    - 22.5K bytes
    - Viewed (0)
  9. android/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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 07 21:36:32 UTC 2024
    - 19K bytes
    - Viewed (0)
  10. android/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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 34.1K bytes
    - Viewed (0)
Back to top