Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 50 for queue (0.13 sec)

  1. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

        /** Runnable is not running and not queued for execution */
        IDLE,
        /** Runnable is not running, but is being queued for execution */
        QUEUING,
        /** runnable has been submitted but has not yet begun execution */
        QUEUED,
        RUNNING,
      }
    
      /** Underlying executor that all submitted Runnable objects are run on. */
      private final Executor executor;
    
      @GuardedBy("queue")
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  2. 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
       */
      public static <E extends @Nullable Object> Queue<E> synchronizedQueue(Queue<E> queue) {
        return Synchronized.queue(queue, null);
      }
    
      /**
       * Returns a synchronized (thread-safe) deque backed by the specified deque. In order to guarantee
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 16K bytes
    - Viewed (0)
  3. 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);
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Mar 07 18:34:03 GMT 2024
    - 36.1K bytes
    - Viewed (0)
  4. 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
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 21:19:52 GMT 2024
    - 34K bytes
    - Viewed (0)
  5. 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.
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 19 19:24:36 GMT 2023
    - 22.5K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/collect/testing/features/FeatureUtil.java

      @CanIgnoreReturnValue
      public static Set<Feature<?>> addImpliedFeatures(Set<Feature<?>> features) {
        Queue<Feature<?>> queue = new ArrayDeque<>(features);
        while (!queue.isEmpty()) {
          Feature<?> feature = queue.remove();
          for (Feature<?> implied : feature.getImpliedFeatures()) {
            if (features.add(implied)) {
              queue.add(implied);
            }
          }
        }
        return features;
      }
    
      /**
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 21 15:08:35 GMT 2022
    - 12.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/Iterables.java

       * {@link Iterators#consumingIterator(Iterator)}.
       *
       * <p>Note: If {@code iterable} is a {@link Queue}, the returned iterable will instead use {@link
       * Queue#isEmpty} and {@link Queue#remove()}, since {@link Queue}'s iteration order is undefined.
       * Calling {@link Iterator#hasNext()} on a generated iterator from the returned iterable may cause
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 24 19:38:27 GMT 2024
    - 42.8K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

          }
        }
      }
    
      /** Invokes {@code queue.}{@link BlockingQueue#take() take()} uninterruptibly. */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      public static <E> E takeUninterruptibly(BlockingQueue<E> queue) {
        boolean interrupted = false;
        try {
          while (true) {
            try {
              return queue.take();
            } catch (InterruptedException e) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 14.4K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

    import static org.junit.Assert.assertThrows;
    
    import com.google.common.collect.ImmutableList;
    import com.google.common.collect.Lists;
    import com.google.common.collect.Queues;
    import java.util.List;
    import java.util.Queue;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.CyclicBarrier;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Executor;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 11.4K bytes
    - Viewed (0)
  10. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

    import com.google.common.collect.Lists;
    import com.google.common.util.concurrent.AbstractFutureBenchmarks.OldAbstractFuture;
    import com.google.errorprone.annotations.concurrent.GuardedBy;
    import java.util.Queue;
    import java.util.concurrent.ArrayBlockingQueue;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.ThreadPoolExecutor;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 17 15:19:38 GMT 2023
    - 20.4K bytes
    - Viewed (0)
Back to top