ArrayBlockingQueue队列

ArrayBlockingQueue

也称为有界队列
基于数组的阻塞队列实现

内部，维护了一个定长数组，便于缓存队列中的数据对象
内部，没有实现读写分离，意味着生产者、消费者不能完全并行

长度需要定义，不指定会报错
可以指定先进先出，或者先进后出

package com.bjsxt.base.coll013;import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.TimeUnit;import javax.swing.text.html.HTMLDocument.Iterator;public class UseQueue {public static void main(String[] args) throws Exception {ArrayBlockingQueue<String> array = new ArrayBlockingQueue<String>(5);array.put("a");array.put("b");array.add("c");array.add("d");array.add("e");System.out.println(array.offer("a", 3, TimeUnit.SECONDS));}
}

3秒之内
如果，a元素加进去了，返回true
如果，a元素没有加进去，返回false

运行

package com.bjsxt.base.coll013;import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.TimeUnit;import javax.swing.text.html.HTMLDocument.Iterator;public class UseQueue {public static void main(String[] args) throws Exception {ArrayBlockingQueue<String> array = new ArrayBlockingQueue<String>(5);array.put("a");array.put("b");array.add("c");array.add("d");array.add("e");array.add("f");System.out.println(array.offer("a", 3, TimeUnit.SECONDS));}
}

定义长度为5
添加6个元素，直接报错

运行

ArrayBlockingQueue队列相关推荐

线程池三种队列使用,SynchronousQueue,LinkedBlockingQueue,ArrayBlockingQueue
使用方法: private static ExecutorService cachedThreadPool = new ThreadPoolExecutor(4, Runtime.getRuntime ...
并发编程（十三）：阻塞队列之ArrayBlockingQueue
一,关联源码链接 * 并发编程(四):AbstractQueuedSynchronizer源码分析 * 并发编程(五):AQS之重入锁ReentrantLock * 并发编程(七):AQS之Condi ...
Java中的5大队列，你知道几个？
作者 | 王磊来源 | Java中文社群(ID:javacn666) 通过前面文章的学习<一文详解「队列」,手撸队列的3种方法!>我们知道了队列(Queue)是先进先出(FIFO)的,并 ...
java add offer_图解Java中的5大队列！（干货收藏）
Java 中的队列有很多,例如:ArrayBlockingQueue.LinkedBlockingQueue.PriorityQueue.DelayQueue.SynchronousQueue等,那它 ...
【Java 并发编程】线程池机制 ( ThreadPoolExecutor 线程池构造参数分析 | 核心线程数 | 最大线程数 | 非核心线程存活时间 | 任务阻塞队列 )
文章目录前言一.ThreadPoolExecutor 构造参数二.newCachedThreadPool 参数分析三.newFixedThreadPool 参数分析四.newSingleTh ...
【学习笔记】抽象队列同步器AQS应用之BlockingQueue详解
文章目录什么是AQS框架 Aqs核心源码基于aqs实现的锁 BlockingQueue ArrayBlockingQueue LinkedBlockingQueue DelayQueue Bloc ...
高性能队列——Disruptor
背景 Disruptor是英国外汇交易公司LMAX开发的一个高性能队列,研发的初衷是解决内存队列的延迟问题(在性能测试中发现竟然与I/O操作处于同样的数量级).基于Disruptor开发的系统单线程能 ...
面试官系统精讲Java源码及大厂真题 - 25 整体设计：队列设计思想、工作中使用场景
25 整体设计:队列设计思想.工作中使用场景人生太短,要干的事太多,我要争分夺秒. --爱迪生引导语本章我们学习了 LinkedBlockingQueue.ArrayBlockingQueue. ...
【重难点】【Java集合 04】ArrayDeque 的使用场景、ArrayBlockingQueue
[重难点][Java集合 04]ArrayDeque 的使用场景.ArrayBlockingQueue 的源码实现文章目录 [重难点][Java集合 04]ArrayDeque 的使用场景.Arra ...

ArrayBlockingQueue队列

ArrayBlockingQueue

ArrayBlockingQueue队列相关推荐

最新文章

热门文章