在Java并发编程中，阻塞队列（BlockingQueue）是一个非常有用的工具。它是一个线程安全的队列，支持生产者-消费者模式，可以解决多线程并发访问的问题。本文将详细介绍阻塞队列的基本概念、实现原理、使用场景以及注意事项。
5.7 Queue并发集合 之前，我们介绍了Queue队列。对于队列的相关知识，你应该有了一个大概的了解！ 在本篇中，我们会继续深入学习，来了解下线程安全的队列集合！ 在Java多线程编程中，生产者消费者模型，想必大家都在熟悉不过了，简单来说就是一部分线程负责向容器中生产，而另一部分线程负责从容器中获取。 在这个模型当中，Java主要利用队列的数据结构进行实现。为了保证数据的安全，Java提供了两种线程安全的Queue队列，分为阻塞队列和非阻塞队列（并发队列）。 其中，阻塞队列典型的实现类是Blocking
阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加的操作支持阻塞的插入和移除方法.
【1】阻塞队列：从定义上来说是队列的一种，那么肯定是一个先进先出（FIFO）的数据结构。与普通队列不同的是，它支持两个附加操作，即阻塞添加和阻塞删除方法。
使用非阻塞队列的时候有一个很大问题就是：它不会对当前线程产生阻塞，那么在面对类似消费者-生产者的模型时，就必须额外地实现同步策略以及线程间唤醒策略，这个实现起来就非常麻烦。但是有了阻塞队列就不一样了，它会对当前线程产生阻塞，比如一个线程从一个空的阻塞队列中取元素，此时线程会被阻塞直到阻塞队列中有了元素。当队列中有元素后，被阻塞的线程会自动被唤醒（不需要我们编写代码去唤醒）。这样提供了极大的方便性。
Java 5 之前实现同步存取时，可以使用普通的一个集合，然后在使用线程的协作和线程同步可以实现生产者，消费者模式，主要的技术就是用好 wait ,notify，notifyAll，sychronized 这些关键字。
前言 在 Android多线程(一)线程池这篇文章时，当我们要创建ThreadPoolExecutor的时候需要传进来一个类型为BlockingQueue的参数，它就是阻塞队列，在这一篇文章里我们会介绍阻塞队列的定义、种类、实现原理以及应用。 1.什么是阻塞队列 阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消费者是从队列里拿元素的线程。阻塞队列就是生产者存放元素的容器，而消费者也只从容器里拿元素。 BlockingQueue有两个常见阻塞场景 当队列中没有数据的情况下，消费者端的所有
Java并发编程：阻塞队列 在前面几篇文章中，我们讨论了同步容器(Hashtable、Vector），也讨论了并发容器（ConcurrentHashMap、CopyOnWriteArrayList），这些工具都为我们编写多线程程序提供了很大的方便。今天我们来讨论另外一类容器：阻塞队列。 在前面我们接触的队列都是非阻塞队列，比如PriorityQueue、LinkedList（LinkedList是双向链表，它实现了Dequeue接口）。 使用非阻塞队列的时候有一个很大问题就是：它不会对当前线程产
一丶什么是阻塞队列 阻塞队列（BlockingQueue）是一个支持两个可以进行阻塞插入和阻塞移除的附加方法的队列。 1）阻塞插入：当队列满后，队列会阻塞（拒绝）插入元素，直到队列不满。 2）阻塞移除：当队列为空时，队列会阻塞（拒绝）移除元素，直到队列里有元素。 ---- 二丶JDK提供的7个阻塞队列 ArrayBlockingQueue：由数组结构组成的有界阻塞队列 LinkedBlockingQueue：由链表结构组成的有界阻塞队列 PriorityBlockingQueue：支持优先级排序的无界
生产者消费者模式最核心的部分是生产者与消费者之间的特殊容器，而阻塞队列是特殊容器最常见的实现。JDK中定义了阻塞队列接口BlockingQueue，JDK通过该接口为我们提供了很多种阻塞队列的实现，其中包括本节的主角ArrayBlockingQueue，该类位于java.util.concurrent.ArrayBlockingQueue.java。该类需要实现的核心方法如下，下面我们详细分析ArrayBlockingQueue的实现原理。
原文地址为https://www.cnblogs.com/haixiang/p/12354520.html，转载请注明出处! 什么是阻塞队列 原文地址为，转载请注明出处! 阻塞队列是一个支持阻塞的
大家都有使用过分布式消息队列，比如 ActiveMQ、 kafka、RabbitMQ 等等，消息队列的是有可以使得程序之 间实现解耦，提升程序响应的效率。 如果我们把多线程环境比作是分布式的话，那么线程与线 程之间是不是也可以使用这种消息队列的方式进行数据通 信和解耦呢？
上次我们讲了一些常用的4个阻塞队列，但是在JDK中还提供了其他的一些阻塞队列。这篇文章将全面介绍一下JDK中的所有阻塞队列，并比较他们的区别。 JDK7提供了7个阻塞队列。分别是 ArrayBlockingQueue ：一个由数组结构组成的有界阻塞队列。 LinkedBlockingQueue ：一个由链表结构组成的有界阻塞队列。 PriorityBlockingQueue ：一个支持优先级排序的无界阻塞队列。 DelayQueue：一个使用优先级队列实现的无界阻塞队列。 Syn
如果线程池的线程数小于corePoolSize(核心线程阈值)，即使其他核心线程处于空闲状态，也会创建一个新核心线程来运行新任务。
1.0 非阻塞队列 在上篇中，我们讲到了阻塞队列，以及阻塞队列中的几个实现类。 本篇，我们继续对队列进行研究。而今天的主题，则是非阻塞队列！在非阻塞队列中，ConcurrentLinkedQueue是主要代表。 之前，我们了解了什么是阻塞队列，在此我们再简单地回顾下！ 什么是阻塞队列？ 阻塞，顾名思义：当我们的生产者向队列中生产数据时，若队列已满，那么生产线程会暂停下来，直到队列中有可以存放数据的地方，才会继续工作；而当我们的消费者向队列中获取数据时，若队列为空，则消费者线程会暂停下来，直到容器中有元素出现
在前面的系列文章中，我们介绍了一下 Java 中多线程的一些主要的知识点和多线程并发程序的设计和处理思想。包括线程的介绍、生命周期、线程的运行控制。之后介绍了如何确保 Java 多线程并发程序的正确性，即通过锁（ReentrantLock 、synchronized ）的思想来实现多线程执行顺序的控制等。如果你对这些还不熟悉，建议看一下前面的文章。接下来我们来看一下 Java 多线程中另一个重要的知识：线程池，在此之前，我们需要了解一下 Java 中的阻塞队列：
在多线程编程中，经常需要使用线程安全的数据结构，用于在不同线程之间进行数据交换和通信。Java提供了一种称为阻塞队列（BlockingQueue）的数据结构，它是线程安全的队列实现，提供了一些特殊的方法来处理多线程环境下的数据交换问题。本文将介绍阻塞队列的基本概念和在Java中使用的三种常见方法：put，add和offer。
在前面我们接触的队列都是非阻塞队列，比如PriorityQueue、LinkedList（LinkedList是双向链表，它实现了Dequeue接口）。
在分析阻塞队列之前我们先看生产者消费者模式，这是一个很常见的模式，生产者负责数据的生产，而消费者则负数据的消费。一般来说生产者与消费者的数量比例是m:n，该模式最大的好处就是将数据生产方与消费方进行了解耦，使得它们之间不会互相影响。为了将生产者和消费者连接起来，我们需要一个特殊的容器，该容器能存储生产者生产的数据，而消费者则能从该容器中取出数据。
今天讲阻塞队列，阻塞队列有很多，这篇文章只讲解ArrayBlockingQueue，其他的大同小异。
【1】阻塞队列的架构图：阻塞队列与 List 具有很多类似之处，对比着学习会更加容易一些。
并发编程之阻塞队列 1. 什么是阻塞队列 阻塞队列（BlockingQueue）是 Java 5 并发新特性中的内容，阻塞队列的接口是 java.util.concurrent.BlockingQue
个参数 : BlockingQueue<Runnable> workQueue ;
BlockingQueue是一个接口，JDK提供了多种阻塞队列的实现方式。我们先看一下这个接口规定了哪些方法。
线程池的作用 减少资源的开销 减少了每次创建线程、销毁线程的开销。 提高响应速度 每次请求到来时，由于线程的创建已经完成，故可以直接执行任务，因此提高了响应速度。 提高线程的可管理性 线程是一种稀缺资源，若不加以限制，不仅会占用大量资源，而且会影响系统的稳定性。 因此，线程池可以对线程的创建与停止、线程数量等等因素加以控制，使得线程在一种可控的范围内运行，不仅能保证系统稳定运行，而且方便性能调优。 线程池的实现原理 线程池一般由两种角色构成：多个工作线程 和 一个阻塞队列。 工作线程
无界阻塞队列永远不满，put和offer方法永远不阻塞，offer永远返回true
在之前的《并发编程踩坑实录一：盘点JDK中同步容器的两大坑！！》一文中，我们主要一起学习了JDK中同步容器的两个坑，一个是在使用同步容器时可能会出现 竞态条件 的问题，一个是在使用同步容器时用 迭代器遍历容器 可能会踩坑。
队列是一种特殊的线性表，遵循先入先出、后入后出的基本原则，一般来说，它只允许在表的前端进行删除操作，而在表的后端进行插入操作，但是java的某些队列运行在任何地方插入删除；比如我们常用的 LinkedList 集合，它实现了Queue 接口，因此，我们可以理解为 LinkedList 就是一个队列；
在上一篇《并发编程踩坑实录一：盘点JDK中同步容器的两大坑！！》中，我们主要一起学习了JDK中同步容器的两个坑，一个是在使用同步容器时可能会出现 竞态条件 的问题，一个是在使用同步容器时用 迭代器遍历容器 可能会踩坑。
阻塞队列与普通队列的不同在于。当队列是空的时候，从队列中获取元素的操作将会被阻塞，或者当队列满时，往队列里面添加元素将会被阻塞。试图从空的阻塞队列中获取元素的线程将会被阻塞，直到其他的线程往空的队列插入新的元素。同样，试图往已满的阻塞队列中添加新元素的线程同样也会被阻塞，直到其他的线程使队列重新变得空闲起来，如从队列中移除一个或者多个元素，或者完全清空队列，下图展示了如何通过阻塞队列来合作：
阻塞队列在多种业务场景中都非常有用，特别是在需要实现生产者-消费者模式、任务调度、线程池等情况下。
阻塞队列与普通队列的区别在于，当队列是空的时，从队列中获取元素的操作将会被阻塞，或者队列是满时，往队列里添加元素的操作会被阻塞。试图从空的阻塞队列中获取元素的线程将会被阻塞，直到其他的线程往空的队列插入新的元素。同样，试图往已满的阻塞队列中添加新元素的线程同样也会被阻塞，直到其他的线程使队列重新变得空闲起来，如从队列中移除一个或者多个元素，或者完全清空队列.
上篇文章我们介绍了队列的基类接口Queue它定义了所有实现队列的类必须拥有的方法行为而BlockingQueue阻塞队列接口继承了Queue接口，此外BlockingQueue队列接口是Java并发包里面所有实现线程安全队列的基类接口。
我们可以看到，ArrayBockingQueue 维护了一个 Object 类型的数组，takeIndex 和 putIndex 分别表示队首元素和队尾元素的下标，count表示队列中元素的个数，接着往下看
阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加的操作是：在队列为空时，获取元素的线程会等待队列变为非空。当队列满时，存储元素的线程会等待队列可用。阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消费者是从队列里拿元素的线程。阻塞队列就是生产者存放元素的容器，而消费者也只从容器里拿元素。
用Java如何设计一个阻塞队列，这个问题是在面滴滴的时候被问到的。当时确实没回答好，只是说了用个List，然后消费者再用个死循环一直去监控list的是否有值，有值的话就处理List里面的内容。回头想想，自己真是一个大傻X，也只有我才会这么设计一个阻塞队列（再说，我这也不是阻塞的队列）。 结果自己面试完之后，也没去总结这部分知识，然后过了一段时间，某教育机构的面试又被问到类似的问题了，只不过是换了一个形式，“请用wait方法和notify方法实现一套有生产者和消费者的这种逻辑”。然后我就又蒙圈了，追悔莫及，为啥我没有去了解一下这部分知识，所以这次我准备好好总结一下这部分内容。
Java 提供的线程安全的 Queue 可以分为阻塞队列和非阻塞队列，其中阻塞队列的典型例子是 BlockingQueue，非阻塞队列的典型例子是 ConcurrentLinkedQueue，在实际应用中要根据实际需要选用阻塞队列或者非阻塞队列。阻塞队列可以通过加锁来实现，非阻塞队列可以通过 CAS 操作实现。
在Java高级开发领域，线程池是一项关键的技术，能够有效地管理和调度多线程任务。Spring Framework 提供了一个强大的线程池实现，即org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor。在这篇博客中，我们将专注于探讨该线程池的阻塞队列，深入了解其种类、特性以及适用的业务场景。
一共100个线程，核心线程数为4，最大线程数为5，空闲存活时间为0，阻塞队列为 4
阻塞队列与普通队列的区别在于，当队列是空的时，从队列中获取元素的操作将会被阻塞，或者当队列是满时，往队列里添加元素的操作会被阻塞。试图从空的阻塞队列中获取元素的线程将会被阻塞，直到其他的线程往空的队列插入新的元素。同样，试图往已满的阻塞队列中添加新元素的线程同样也会被阻塞，直到其他的线程使队列重新变得空闲起来，如从队列中移除一个或者多个元素，或者完全清空队列，下图展示了如何通过阻塞队列来合作：
阻塞队列，也就是 BlockingQueue，它是一个接口。BlockingQueue是基于阻塞机制实现的线程安全的队列。而阻塞机制的实现是通过在入队和出队时加锁的方式避免并发操作。
通过前面文章的学习，我们对Java中常用队列做了介绍。本文，咱们来对队列做个总结吧。
生产者消费者模型 生产者消费者模式就是通过一个容器来解决生产者和消费者的强耦合问题。生产者和消费者彼此之间不直接通讯，而通过阻塞队列来进行通讯，所以生产者生产完数据之后不用等待消费者处理，直接扔给阻塞队列，消费者不找生产者要数据，而是直接从阻塞队列里取，阻塞队列就相当于一个缓冲区，平衡了生产者和消费者的处理能力。这个阻塞队列就是用来给生产者和消费者解耦的。
BlockingQueue 对插入操作、移除操作、获取元素操作提供了四种不同的方法用于不同的场景中使用：
具体细节说明文章：Java线程池Executor详解 本文以Executors.newFixedThreadPool为例 定长线程池，核心线程数和最大线程数由用户传入，超出在队列等待，以下为相关源码。
阻塞队列，顾名思义，首先它是一个队列，而一个阻塞队列在数据结构中所起的作用大致如下图所示：
在上一篇《亿级流量高并发秒杀系统商品“超卖”了，只因使用的JDK同步容器中存在这两个巨大的坑！！（踩坑实录，建议收藏）》中，我们主要一起学习了JDK中同步容器的两个坑，一个是在使用同步容器时可能会出现 竞态条件 的问题，一个是在使用同步容器时用 迭代器遍历容器 可能会踩坑。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
