java操作ArrayBlockingQueue
时间: 2023-10-14 15:15:25 浏览: 44
Java中的ArrayBlockingQueue是一种基于数组的有界阻塞队列,它有固定大小,并且一旦创建就不能改变大小。它提供了先进先出的队列操作,并且支持阻塞队列的特性,即当队列为空时,队列的读取操作会被阻塞,直到有新的元素被添加到队列中;当队列满时,队列的插入操作会被阻塞,直到有元素被取出队列中。
以下是一些常用的操作:
1. 创建ArrayBlockingQueue对象:
```java
ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(capacity);
```
其中,capacity指定了队列的大小。
2. 添加元素到队列中:
```java
queue.add(element);//当队列满时会抛出IllegalStateException异常
queue.offer(element);//当队列满时会返回false
queue.put(element);//当队列满时会阻塞
```
3. 从队列中取出元素:
```java
queue.take();//当队列为空时会阻塞
queue.poll();//当队列为空时会返回null
queue.poll(timeout, TimeUnit);//当队列为空时会等待一段时间,超时返回null
```
4. 获取队列中的元素个数:
```java
queue.size();
```
5. 判断队列是否为空或已满:
```java
queue.isEmpty();
queue.isFull();//ArrayBlockingQueue没有提供isFull方法,但可以通过判断size和capacity是否相等来实现
```
6. 循环遍历队列:
```java
for (Integer i : queue) {
// do something
}
```
注意:ArrayBlockingQueue是线程安全的,可以在多线程环境下使用,但需要注意使用同步措施,如锁或同步块等。