- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for PriorityBlockingQueue (0.06 sec)
-
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 Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Nov 04 17:24:58 UTC 2025 - 18K bytes - Viewed (0) -
src/main/java/org/codelibs/core/collection/CollectionsUtil.java
* Creates and returns a new instance of {@link PriorityBlockingQueue}. * * @param <E> the element type of {@link PriorityBlockingQueue} * @return a new instance of {@link PriorityBlockingQueue} * @see PriorityBlockingQueue#PriorityBlockingQueue() */ public static <E> PriorityBlockingQueue<E> newPriorityBlockingQueue() { return new PriorityBlockingQueue<>(); } /**Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 49.9K bytes - Viewed (0) -
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 Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Nov 04 17:24:58 UTC 2025 - 18.2K bytes - Viewed (0) -
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.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /**
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Nov 04 17:24:58 UTC 2025 - 12.6K bytes - Viewed (0) -
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 Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:45:32 UTC 2025 - 22.6K bytes - Viewed (0) -
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 Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:45:32 UTC 2025 - 22.2K bytes - Viewed (0)