Uses of Interface
java.util.concurrent.BlockingQueue
-
Packages that use BlockingQueue 软件包 描述 java.util.concurrent 实用程序类通常用于并发编程。 -
-
Uses of BlockingQueue in java.util.concurrent
Subinterfaces of BlockingQueue in java.util.concurrent Modifier and Type 接口 描述 interface
BlockingDeque<E>
ADeque
另外支持在检索元素时等待deque变为非空的阻塞操作,并且在存储元素时等待空白在deque中可用。interface
TransferQueue<E>
ABlockingQueue
,其中生产者可能等待消费者接收元素。Classes in java.util.concurrent that implement BlockingQueue Modifier and Type Class 描述 class
ArrayBlockingQueue<E>
有限的blocking queue由阵列支持。class
DelayQueue<E extends Delayed>
一个无限制的blocking queue的Delayed
元素,其中元素只能在其延迟到期时才被使用。class
LinkedBlockingDeque<E>
基于链接节点的可选限定的blocking deque 。class
LinkedBlockingQueue<E>
基于链接节点的可选限定的blocking queue 。class
LinkedTransferQueue<E>
基于链接节点的无界TransferQueue
。class
PriorityBlockingQueue<E>
无限blocking queue使用与PriorityQueue
类相同的排序规则,并提供阻止检索操作。class
SynchronousQueue<E>
A blocking queue其中每个插入操作必须等待另一个线程相应的删除操作,反之亦然。Methods in java.util.concurrent that return BlockingQueue Modifier and Type 方法 描述 BlockingQueue<Runnable>
ScheduledThreadPoolExecutor. getQueue()
返回此执行程序使用的任务队列。BlockingQueue<Runnable>
ThreadPoolExecutor. getQueue()
返回此执行程序使用的任务队列。Constructors in java.util.concurrent with parameters of type BlockingQueue Constructor 描述 ExecutorCompletionService(Executor executor, BlockingQueue<Future<V>> completionQueue)
使用提供的执行程序创建一个ExecutorCompletionService,用于执行基本任务,并将提供的队列作为其完成队列。ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
创建一个新的ThreadPoolExecutor
与给定的初始参数和默认线程工厂和拒绝执行处理程序。ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler)
创建一个新的ThreadPoolExecutor
与给定的初始参数和默认线程工厂。ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory)
创建一个新的ThreadPoolExecutor
与给定的初始参数和默认拒绝执行处理程序。ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)
用给定的初始参数创建一个新的ThreadPoolExecutor
。
-