Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for PriorityBlockingQueue (0.1 sec)

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

      @J2ktIncompatible
      @GwtIncompatible // PriorityBlockingQueue
      public static <E extends Comparable> PriorityBlockingQueue<E> newPriorityBlockingQueue(
          Iterable<? extends E> elements) {
        if (elements instanceof Collection) {
          return new PriorityBlockingQueue<>((Collection<? extends E>) elements);
        }
        PriorityBlockingQueue<E> queue = new PriorityBlockingQueue<>();
        Iterables.addAll(queue, elements);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/Queues.java

      @J2ktIncompatible
      @GwtIncompatible // PriorityBlockingQueue
      public static <E extends Comparable> PriorityBlockingQueue<E> newPriorityBlockingQueue(
          Iterable<? extends E> elements) {
        if (elements instanceof Collection) {
          return new PriorityBlockingQueue<>((Collection<? extends E>) elements);
        }
        PriorityBlockingQueue<E> queue = new PriorityBlockingQueue<>();
        Iterables.addAll(queue, elements);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/collect/QueuesTest.java

    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.LinkedBlockingDeque;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.PriorityBlockingQueue;
    import java.util.concurrent.SynchronousQueue;
    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  4. android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java

    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.ConcurrentNavigableMap;
    import java.util.concurrent.DelayQueue;
    import java.util.concurrent.Executor;
    import java.util.concurrent.PriorityBlockingQueue;
    import java.util.concurrent.SynchronousQueue;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicBoolean;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  5. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

     * @param <E> the type of elements held in this collection
     */
    public class MonitorBasedPriorityBlockingQueue<E> extends AbstractQueue<E>
        implements BlockingQueue<E> {
    
      // Based on revision 1.55 of PriorityBlockingQueue by Doug Lea, from
      // http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/main/java/util/concurrent/
    
      private static final long serialVersionUID = 5595510919245408276L;
    
      final PriorityQueue<E> q;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 07 21:36:32 UTC 2024
    - 19K bytes
    - Viewed (0)
Back to top