1700451531
1700451532
at java.util.AbstractQueue.add(AbstractQueue.java:71)
1700451533
1700451534
at java.util.concurrent.ArrayBlockingQueue.add(ArrayBlockingQueue.java:209)
1700451535
1700451536
at Client.main(Client.java:12)
1700451537
1700451538
没错,报队列已满异常,这是阻塞队列和非阻塞队列一个重要区别:阻塞队列的容量是固定的,非阻塞队列则是变长的。阻塞队列可以在声明时指定队列的容量,若指定的容量,则元素的数量不可超过该容量,若不指定,队列的容量为Integer的最大值。
1700451539
1700451540
阻塞队列和非阻塞队列有此区别的原因是阻塞队列是为了容纳(或排序)多线程任务而存在的,其服务的对象是多线程应用,而非阻塞队列容纳的则是普通的数据元素。我们来看一下ArrayBlockingQueue类最常用的add方法。
1700451541
1700451542
public class ArrayBlockingQueue<E>extends AbstractQueue<E>
1700451543
1700451544
implements BlockingQueue<E>,java.io.Serializable{
1700451545
1700451546
//容纳元素的数组
1700451547
1700451548
private final E[]items;
1700451549
1700451550
//元素数量计数器
1700451551
1700451552
private int count;
1700451553
1700451554
public boolean add(E e){
1700451555
1700451556
//调用offer方法尝试写入
1700451557
1700451558
if(offer(e))
1700451559
1700451560
return true;
1700451561
1700451562
else
1700451563
1700451564
//写入失败,队列已满
1700451565
1700451566
throw new IllegalStateException(“Queue full”);
1700451567
1700451568
}
1700451569
1700451570
public boolean offer(E e){
1700451571
1700451572
final ReentrantLock lock=this.lock;
1700451573
1700451574
//申请锁,只允许同时有一个线程操作
1700451575
1700451576
lock.lock();
1700451577
1700451578
try{
1700451579
1700451580
//元素计数器的计数与数组长度相同,表示队列已满
[
上一页 ]
[ :1.700451531e+09 ]
[
下一页 ]