Uses of Interface
java.util.concurrent.BlockingQueue
Packages that use BlockingQueue
-
Uses of BlockingQueue in java.util.concurrent
Subinterfaces of BlockingQueue in java.util.concurrentModifier and TypeInterfaceDescriptioninterfaceADequethat additionally supports blocking operations that wait for the deque to become non-empty when retrieving an element, and wait for space to become available in the deque when storing an element.interfaceABlockingQueuein which producers may wait for consumers to receive elements.Classes in java.util.concurrent that implement BlockingQueueModifier and TypeClassDescriptionclassA bounded blocking queue backed by an array.classDelayQueue<E extends Delayed>An unbounded blocking queue ofDelayedelements, in which an element can only be taken when its delay has expired.classAn optionally-bounded blocking deque based on linked nodes.classAn optionally-bounded blocking queue based on linked nodes.classAn unboundedTransferQueuebased on linked nodes.classAn unbounded blocking queue that uses the same ordering rules as classPriorityQueueand supplies blocking retrieval operations.classA blocking queue in which each insert operation must wait for a corresponding remove operation by another thread, and vice versa.Methods in java.util.concurrent that return BlockingQueueModifier and TypeMethodDescriptionScheduledThreadPoolExecutor.getQueue()Returns the task queue used by this executor.ThreadPoolExecutor.getQueue()Returns the task queue used by this executor.Constructors in java.util.concurrent with parameters of type BlockingQueueModifierConstructorDescriptionExecutorCompletionService(Executor executor, BlockingQueue<Future<V>> completionQueue) Creates an ExecutorCompletionService using the supplied executor for base task execution and the supplied queue as its completion queue.ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) Creates a newThreadPoolExecutorwith the given initial parameters, the default thread factory and the default rejected execution handler.ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler) Creates a newThreadPoolExecutorwith the given initial parameters and the default thread factory.ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory) Creates a newThreadPoolExecutorwith the given initial parameters and the default rejected execution handler.ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) Creates a newThreadPoolExecutorwith the given initial parameters.