BlockingQueue 是java.util.concurrent包 下的接口。
阻塞队列:当队列满时,入队线程会被阻塞;当队列为空时,出队线程会被阻塞. put / take
参考:https://www.cnblogs.com/lemon-flm/p/7877898.html
ArrayBlockingQueue在构造时需要指定容量, 并可以选择是否需要公平性,如果公平参数被设置true,等待时间最长的线程会优先得到处理(其实就是通过将ReentrantLock的fair设置为true来 达到这种公平性的:即等待时间最长的线程会先操作)。
通常,公平性会使你在性能上付出代价,只有在的确非常需要的时候再使用它。它是基于数组的阻塞循环队列,此队列按 FIFO(先进先出)原则对元素进行排序。
package com.dh.test;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class LearnArrayBlockingQueue {// ArrayBlockingQueue 利用的ReentrantLock的Condition中的方法:await()释放锁,阻塞当前线程; single()唤醒线程
public static void main(String[] args) throws InterruptedException {
//ArrayBlockingQueue队列是通过数组来实现的,所以new 该队列时,需要指定初始容量大小。
BlockingQueue<String> arrayBlockingQueue = new ArrayBlockingQueue<>(2);
arrayBlockingQueue.offer("aaaa");
arrayBlockingQueue.offer("bbbb");
// 会抛异常 Queue full
// arrayBlockingQueue.add("dddd");
// 不会抛异常,返回false
arrayBlockingQueue.offer("cccc");
//在添加元素时,ArrayBlockingQueue使用了ReentrantLock用来保证线程安全使用了ReentrantLock用来保证线程安全。
//默认情况下,ArrayBlockingQueue的构造方法默认fair为false,
arrayBlockingQueue.take();
arrayBlockingQueue.take();
//此时队列为空,出队线程会被阻塞 notEmpty.await()
Thread thread = new Thread(new MyThread(arrayBlockingQueue));
thread.start();
//take会一直阻塞,直到线程给队列放值
System.out.println(arrayBlockingQueue.take());
}
}
class MyThread implements Runnable {
BlockingQueue<String> arrayBlockingQueue;
public MyThread(BlockingQueue<String> arrayBlockingQueue) {
this.arrayBlockingQueue = arrayBlockingQueue;
}
@Override
public void run() {
System.out.println("给队列放值,让队列不为空");
arrayBlockingQueue.offer("eeee");
}
}