ArrayBlockingQueue

Queue设计出来的目标就是为了高并发，而在多线程中BlockingQueue扮演至关重要的角色，因为它提供了很多对多线程友好的接口。

ArrayBlockingQueue是一个阻塞式队列，并且是有界队列需要指定容量。通过继承关系图可以知道ArrayBlockingQueue继承自AbstractQueue并实现了BlockingQueue,间接的实现了Queue接口和Collection接口，全局锁是ReentrantLock，通过数组来保存数据，常用的操作包括：

• offer(E e)：插入元素，如果队列满了则返回false，否则返回true
• add(E e)：插入元素，如果队列满了则抛异常，否则返回true
• put(E e)：插入元素，如果队列满了则阻塞，直到能把元素插入进去
• poll()：取出一个元素，如果队列为空则返回null，否则将取出排在首位的元素
• poll(long timeout, TimeUnit unit)：取出排在首位的元素，如果为空则等待规定时间，依旧为空则返回null
• take()：取出一个元素，如果队列为空则阻塞，直到取出元素
• remainingCapacity(): 获取队列剩余空间

代码示例

public class TestArrayBlockingQueue {

    static BlockingQueue abq = new ArrayBlockingQueue<>(4);

    public static void main(String[] args) throws InterruptedException {
        insertDemo();
        //getDemo();
    }

    static void insertDemo() throws InterruptedException {
        for(int i = 0; i < 4; i++) {
            abq.put(i);
        }
        // 程序会阻塞
        //abq.put(1);
        // 程序会抛异常
        //abq.add(1);
        // 返回false
        System.out.println(abq.offer(1));;
        // 阻塞1秒后返回false
        System.out.println(abq.offer(1, 1, TimeUnit.SECONDS));;
    }

    static void getDemo() throws InterruptedException {
        // 程序会阻塞
        //System.out.println(abq.take());
        // 返回null
        //System.out.println(abq.poll());
        // 阻塞1秒后返回null
        System.out.println(abq.poll(1, TimeUnit.SECONDS));
    }