- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for newLinkedBlockingQueue (0.1 seconds)
-
android/guava/src/com/google/common/collect/Queues.java
/** Creates an empty {@code LinkedBlockingQueue} with a capacity of {@link Integer#MAX_VALUE}. */ @J2ktIncompatible @GwtIncompatible // LinkedBlockingQueue public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue() { return new LinkedBlockingQueue<>(); } /** * Creates an empty {@code LinkedBlockingQueue} with the given (fixed) capacity. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 18.2K bytes - Click Count (0) -
guava/src/com/google/common/collect/Queues.java
/** Creates an empty {@code LinkedBlockingQueue} with a capacity of {@link Integer#MAX_VALUE}. */ @J2ktIncompatible @GwtIncompatible // LinkedBlockingQueue public static <E> LinkedBlockingQueue<E> newLinkedBlockingQueue() { return new LinkedBlockingQueue<>(); } /** * Creates an empty {@code LinkedBlockingQueue} with the given (fixed) capacity. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 18K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
checkNotNull(unit); int ntasks = tasks.size(); checkArgument(ntasks > 0); List<Future<T>> futures = Lists.newArrayListWithCapacity(ntasks); BlockingQueue<Future<T>> futureQueue = Queues.newLinkedBlockingQueue(); long timeoutNanos = unit.toNanos(timeout); // For efficiency, especially in executors with limited // parallelism, check to see if previously submitted tasks are
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 45.6K bytes - Click Count (0)