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 变量和类型 接口 描述 interface
BlockingDeque<E>
Deque
还支持阻塞操作,这些阻塞操作在检索元素时等待deque变为非空,并在存储元素时等待deque中的空间可用。interface
TransferQueue<E>
BlockingQueue
,生产者可以等待消费者接收元素。Classes in java.util.concurrent that implement BlockingQueue 变量和类型 类 描述 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>
blocking queue ,其中每个插入操作必须等待另一个线程的相应移除操作,反之亦然。Methods in java.util.concurrent that return BlockingQueue 变量和类型 方法 描述 BlockingQueue<Runnable>
ScheduledThreadPoolExecutor. getQueue()
返回此执行程序使用的任务队列。BlockingQueue<Runnable>
ThreadPoolExecutor. getQueue()
返回此执行程序使用的任务队列。Constructors in java.util.concurrent with parameters of type BlockingQueue 构造器 描述 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
给定的初始参数和 default thread factory 。ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory)
创建具有给定初始参数的新ThreadPoolExecutor
和default rejected execution handler 。ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)
使用给定的初始参数创建新的ThreadPoolExecutor
。
-