- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for PriorityBlockingQueue (0.07 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) -
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)