java.util.concurrent.Queue 并发队列

时间:2021-02-21 17:37:24

1. ConcurrentLinkedQueue

Queue的一个线程安全实现,见下:
public class  ConcurrentLinkedQueue<E> extends  AbstractQueue<E>   implements  Queue<E>, java.io.Serializable {}

2.BlockingQueue 阻塞队列

这是一个线程安全的接口,见下:

public interface BlockingQueue<E> extends Queue<E>

它的一些常用方法见下:

void java.util.concurrent.BlockingQueue.put(E e)

put方法在队列满的时候会阻塞,直到有队列成员被消费。

E java.util.concurrent.BlockingQueue.take()

take方法在队列空的时候会阻塞,直到有队列成员被放进来。

int java.util.concurrent.BlockingQueue.drainTo(Collection<? super E> c)

把队列中的元素倾倒给实参c。适用于生产者一直生产,消费者定时消费的场景。如果消费者的消费行为是IO操作,那么定时可以达到缓存效果,节省IO。

它有两个实现类,LinkedBlockingQueue与ArrayBlockingQueue。

2.1 LinkedBlockingQueue

public class LinkedBlockingQueue<E> extends AbstractQueue<E>  implements BlockingQueue<E>, java.io.Serializable {}

由于LinkedBlockingQueue实现是线程安全的,实现了先进先出等特性,是作为生产者消费者的首选。LinkedBlockingQueue 可以指定容量,也可以不指定,不指定的话,默认最大是Integer.MAX_VALUE。

2.2 ArrayBlockingQueue

它是阻塞队列的另外一个实现,见下:

public class ArrayBlockingQueue<E> extends AbstractQueue<E> implements BlockingQueue<E>, java.io.Serializable {}