Java中的ArrayBlockingQueue add()方法

介绍

Java中的ArrayBlockingQueue是一个线程安全的阻塞队列，可以用于多线程间的数据传递和同步。加入元素的方法有两个：add()和put()。

add()方法会将指定元素插入此队列的尾部，并返回true，如果队列已满，则会抛出IllegalStateException异常。

import java.util.concurrent.ArrayBlockingQueue;

public class Test {
    public static void main(String[] args) {
        ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(2);
        queue.add(1);
        queue.add(2);
        System.out.println(queue.add(3)); // 抛出IllegalStateException异常
    }
}

put()方法也会将指定元素插入此队列的尾部，但如果队列已满，则会阻塞线程直到队列有空闲空间。

import java.util.concurrent.ArrayBlockingQueue;

public class Test {
    public static void main(String[] args) throws InterruptedException {
        ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(2);
        queue.put(1);
        queue.put(2);
        queue.put(3); // 线程会被阻塞，直到队列有空闲空间
    }
}

add()方法的实现

add()方法的实现相对简单，只需要调用offer()方法将元素插入队列，并在插入失败时抛出异常。

public boolean add(E e) {
    if (offer(e))
        return true;
    else
        throw new IllegalStateException("Queue full");
}

结论

ArrayBlockingQueue的add()方法实现简单，但不够灵活。如果队列已满，会抛出异常，而put()方法则会阻塞线程等待有空闲空间。因此，在使用add()方法时需要注意队列的容量。如果需要更灵活的插入方式，可以使用offer()方法，该方法会返回插入结果，不会阻塞线程。