接口的使用
java.util.concurrent.BlockingQueue
使用 BlockingQueue 的包
-
BlockingQueue 在 java.util.concurrent 中的用法
修饰符和类型接口描述interface一个Deque还支持阻塞操作,在检索元素时等待双端队列变为非空,并在存储元素时等待双端队列中的空间可用。interfaceBlockingQueue,生产者可以在其中等待消费者接收元素。修饰符和类型类描述class由数组支持的有界 阻塞队列。classDelayQueue<E extends Delayed>一个无界的 阻塞队列 ofDelayed元素,其中一个元素只有在其延迟到期时才能被获取。class基于链接节点的可选边界 阻塞双端队列。class基于链接节点的可选边界 阻塞队列。class基于链接节点的无界TransferQueue。class一个无界的 阻塞队列,它使用与类PriorityQueue相同的排序规则并提供阻塞检索操作。classA 阻塞队列 其中每个插入操作必须等待另一个线程的相应删除操作,反之亦然。java.util.concurrent 中返回 BlockingQueue 的方法修饰符和类型方法描述ScheduledThreadPoolExecutor.getQueue()返回此执行程序使用的任务队列。ThreadPoolExecutor.getQueue()返回此执行程序使用的任务队列。java.util.concurrent 中的构造函数,参数类型为 BlockingQueue修饰符构造方法描述ExecutorCompletionService(Executor executor, BlockingQueue<Future<V>> completionQueue) 使用提供的执行器执行基本任务并使用提供的队列作为其完成队列创建 ExecutorCompletionService。ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) 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。