阻塞队列

概述

  • 什么是阻塞队列?
  • 阻塞队列,顾名思义,首先它是一个队列,而一个阻塞队列在数据结构中所起的作用大致如图所示
  • 当阻塞队列是空时,从队列中获取元素的操作将会被阻塞，当阻塞队列是满时,往队列中添加元素的操作将会被阻塞

1660913142746

为什么用?有什么好处?

好处是我们不需要关心什么时候需要阻塞线程,什么时候需要唤醒线程,因为 BlockingQueue 都一手给你包办好了

在 concurrent 包发布以前,在多线程环境下,我们每个程序员都必须自己去控制这些细节,尤其还要兼顾效率和线程安全,而这会给我们的程序带来不小的复杂度.

阻塞队列种类

阻塞队列种类

  1. ArrayBlockingQueue: 由数组结构组成的有界阻塞队列
  2. LinkedBlockingQueue: 由链表结构组成的有界(但大小默认值 Integer>MAX.VALUE)阻塞队列.
  3. SynchronousQueue:不存储元素的阻塞队列,也即是单个元素的队列.
    • SynchronousQueue没有容量，与其他BlcokingQueue不同,SynchronousQueue 是一个不存储元素的BlcokingQueue
    • 每个put操作必须要等待一个take操作,否则不能继续添加元素,反之亦然
  4. PriorityBlockingQueue : 支持优先级排序的无界阻塞队列.
  5. LinkedTransferQueue : 由链表结构组成的无界阻塞队列.
  6. LinkedBlockingDeque : 由链表结构组成的双向阻塞队列.

BlockingQueue的核心方法

1660917472794

1660917510175

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
package tech.chen.juccode.a04;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;

/**
 * @Date 2022/8/19 22:48
 * @Author c-z-k
 */
public class BlockingQueueDemo {
    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<String> blockingQueue = new ArrayBlockingQueue(3);
        blockingQueue.add("a");
        blockingQueue.add("b");
        blockingQueue.add("c");
        System.out.println(blockingQueue.element());//a
//        blockingQueue.add("d");//Queue full
        System.out.println(blockingQueue.take());//a
        System.out.println(blockingQueue.take());//b
        System.out.println(blockingQueue.take());//c

        System.out.println(blockingQueue.size());//0

        blockingQueue.offer("a",2, TimeUnit.SECONDS);
        blockingQueue.offer("b",2, TimeUnit.SECONDS);
        blockingQueue.offer("c",2, TimeUnit.SECONDS);
        blockingQueue.offer("d",2, TimeUnit.SECONDS);//不报错，但会阻塞两秒
    }
}