Java BlockingQueue add()方法及示例
BlockingQueue 接口的 add(E e) 方法在有空间的情况下将参数中传递的元素插入到队列的末端。如果BlockingQueue os容量受限,没有空间可供插入,它会返回IllegalStateException。
语法
public void add(E e)
参数: 该方法接受一个强制参数 e ,它是要插入BlockingQueue末端的元素。
返回: 该方法在成功插入时返回true。
异常 。
- IllegalStateException : 如果由于容量的限制,这个元素在这个时候不能被添加。
- NullPointerException : 如果指定的元素是空的。
注意 : BlockingQueue 的 add() 方法继承自Java的 Queue 类。
以下程序说明了BlockingQueue的add()方法。
程序1 :
// Java Program Demonstrate add()
// method of BlockingQueue
import java.util.*;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingDeque;
public class GFG {
public static void main(String[] args)
throws IllegalStateException
{
// create object of BlockingQueue
BlockingQueue<Integer> BQ
= new LinkedBlockingDeque<Integer>();
// Add numbers to the BlockingQueue
BQ.add(7855642);
BQ.add(35658786);
BQ.add(5278367);
BQ.add(74381793);
// before removing print BlockingQueue
System.out.println("Blocking Queue: " + BQ);
}
}
输出
Blocking Queue: [7855642, 35658786, 5278367, 74381793]
程序2 :
// Java Program Demonstrate add()
// method of LinkedBlockingDeque
// when null is inserted
import java.util.*;
import java.util.concurrent.LinkedBlockingDeque;
public class GFG {
public static void main(String[] args)
throws IllegalStateException
{
// create object of LinkedBlockingDeque
LinkedBlockingDeque<Integer> BQ
= new LinkedBlockingDeque<Integer>();
// Add numbers to end of LinkedBlockingDeque
BQ.add(7855642);
BQ.add(35658786);
BQ.add(5278367);
// NULL
BQ.add(null);
// before removing print Deque
System.out.println("Linked Blocking Deque: " + BQ);
}
}
输出:
Exception in thread "main" java.lang.IllegalStateException: Deque full
at java.util.concurrent.LinkedBlockingDeque.addLast(LinkedBlockingDeque.java:335)
at java.util.concurrent.LinkedBlockingDeque.add(LinkedBlockingDeque.java:633)
at GFG.main(GFG.java:25)
**参考资料: **https: //docs.oracle.com/javase/7/docs/api/java/util/concurrent/BlockingQueue.html#add(E)