arrayblockingqueue的take和poll
时间: 2023-09-13 12:13:04 浏览: 71
ArrayBlockingQueue是Java中的一个阻塞队列,提供了两个方法take和poll来从队列中获取元素。
- take方法会一直阻塞直到队列中有可用的元素,当队列为空时,线程将会一直等待直到队列中有新的元素被添加进来。
- poll方法则是会立即返回队列中的元素,如果队列为空,则返回null。
需要注意的是,当ArrayBlockingQueue为空时,take方法将会一直阻塞,而poll方法则会立即返回null。此外,take方法和poll方法都会自动检查队列中是否有可用的元素,因此不需要手动加锁或等待条件。
相关问题
ArrayBlockingQueue
ArrayBlockingQueue是一个由数组实现的有界阻塞队列。它的大小是固定的,由构造函数中指定的容量决定。ArrayBlockingQueue内部使用了重入锁ReentrantLock和Condition条件队列来实现阻塞和唤醒线程的操作。它具有公平访问和非公平访问两种方式。
对于公平访问队列,被阻塞的线程可以按照阻塞的先后顺序访问队列,即先阻塞的线程先访问队列。而非公平队列,则是当队列可用时,阻塞的线程将进入争夺访问资源的竞争中,谁先抢到谁就执行,没有固定的先后顺序。
ArrayBlockingQueue的构造方法中,可以通过传入boolean类型的fair参数来选择是创建公平阻塞队列还是非公平阻塞队列。
LinkedBlockingQueue是一个由链表实现的有界阻塞队列。它的默认大小为Integer.MAX_VALUE,因此建议在使用LinkedBlockingQueue时手动传入所需的大小,避免队列过大导致机器负载过高或内存溢出等问题。
以下是ArrayBlockingQueue和LinkedBlockingQueue的基本概要:
- ArrayBlockingQueue:
- 类型:由数组实现的有界阻塞队列。
- 特点:具有公平访问和非公平访问两种方式。
- 构造函数:可以指定初始容量和是否使用公平访问。
- 方法:put()、take()、offer()、poll()等常用方法。
- LinkedBlockingQueue:
- 类型:由链表实现的有界阻塞队列。
- 特点:默认大小为Integer.MAX_VALUE,建议手动传入所需大小。
- 构造函数:可以指定初始容量或从其他集合中添加元素。
- 方法:put()、take()、offer()、poll()等常用方法。
java操作ArrayBlockingQueue
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是线程安全的,可以在多线程环境下使用,但需要注意使用同步措施,如锁或同步块等。