接口 java.util.concurrent.BlockingQueue 的使用 (Java 2 Platform SE 5.0) - JavaTM 2 Platform Standard Edition 5.0 API 规范中文版

java.util.concurrent 中 BlockingQueue 的使用

 

实现 BlockingQueue 的 java.util.concurrent 中的类
class	ArrayBlockingQueue<E>           一个由数组支持的有界阻塞队列。
class	DelayQueue<E extends Delayed>           Delayed 元素的一个无界阻塞队列，只有在延迟期满时才能从中提取元素。
class	LinkedBlockingQueue<E>           一个基于已链接节点的、范围任意的 blocking queue。
class	PriorityBlockingQueue<E>           一个无界的阻塞队列，它使用与类 PriorityQueue 相同的顺序规则，并且提供了阻塞检索的操作。
class	SynchronousQueue<E>           一种阻塞队列，其中每个 put 必须等待一个 take，反之亦然。

 

返回 BlockingQueue 的 java.util.concurrent 中的方法
BlockingQueue<Runnable>	ThreadPoolExecutor.getQueue()           返回此执行程序使用的任务队列。
BlockingQueue<Runnable>	ScheduledThreadPoolExecutor.getQueue()           返回此执行程序使用的任务队列。

 

参数类型为 BlockingQueue 的 java.util.concurrent 中的构造方法
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。

 

版权所有 2004 Sun Microsystems, Inc. 保留所有权利。 请遵守许可证条款。另请参阅文档重新分发政策。