首页 > 编程语言 >Java并发编程：第六章 阻塞队列

Java并发编程：第六章 阻塞队列

时间：2024-03-25 19:30:02浏览次数：25  
标签：元素 Java Thread 队列 编程 LinkedBlockingQueue 阻塞 线程

文章目录

一、BlockQueue

1、特点

阻塞队列与普通队列（ArrayDeque等）之间的最大不同点在于阻塞队列提供了阻塞式的添加和删除方法：

  • 阻塞添加
    所谓的阻塞添加是指当阻塞队列元素已满时，队列会阻塞添加元素的线程，知道队列元素不满时，才重新唤醒线程执行元素添加操作。
  • 阻塞删除
    阻塞删除是指在队列元素为空时，删除队列元素的线程将被阻塞，直到队列不为空时，才重新唤醒删除线程再执行删除操作。

2、阻塞队列常用方法

  • 添加类方法
    • add(E e)
      添加成功则返回true，失败就抛出IllegalStateException异常。
    • offer(E e)
      成功则返回true，如果此队列已满就返回false。
    • put(E e)
      将元素添加到此队列的尾部，如果该队列已满，就一直阻塞。
  • 删除类方法
    • poll()
      获取并移除此队列的队首元素，若队列为空，则返回null。
    • remove(Object o)
      移除指定元素，成功则返回true，失败则返回false。
    • take()
      获取并移除此队列的队首元素，若没有元素，则一直阻塞。
  • 获取元素类方法
    • element()
      获取但不移除此队列的队首元素，没有元素则抛出异常。
    • peek()
      获取但不移除此队列的队首元素，若队列为空，则返回null。

二、常见的BlockingQueue

1、介绍

不同的BlockingQueue子类之间的区别主要体现在元素存储结构和元素操作上。

2、ArrayBlockingQueue

ArrayBlockingQueue 是 Java 并发包 java.util.concurrent 中的一个类，它实现了一个基于数组的有界阻塞队列。这个队列按照 FIFO（先进先出）的原则对元素进行排序。以下是 ArrayBlockingQueue 的一些主要特点和功能：

  • 有界性： ArrayBlockingQueue有界且固定，在构造函数时确认大小，确认后不支持改变。其内部使用一个定长数组存储元素。除了一个定长数组外，ArrayBlockingQueue内部还保存着两个整型变量，分别标识队列的头部和尾部在数组中的位置。一旦队列已满，任何试图向队列中插入元素的线程都将被阻塞，直到队列中有可用的空间。同样，如果队列为空，任何试图从队列中移除元素的线程都将被阻塞，直到队列中有新的元素。
  • 线程安全：ArrayBlockingQueue的添加和删除操作都是公用同一个锁对象，因此添加和删除无法并行运行。
  • 性能：由于 ArrayBlockingQueue 是基于数组实现的，因此在内存布局上更加紧凑，并且在随机访问元素时性能较好。然而，如果频繁地在队列头部和尾部进行插入和删除操作，性能可能不如 LinkedBlockingQueue，因为 LinkedBlockingQueue 是基于链表实现的，更适合动态调整大小。
  • 公平性：ArrayBlockingQueue 支持公平性。公平性是指按照线程等待的顺序来处理它们，即等待时间最长的线程将优先得到处理。可以通过构造函数中的 fair 参数来设置队列是否为公平的。当设置为 true 时，等待时间最长的线程将获得优先处理；当设置为 false 时，则不保证这种顺序。
  • 可选的迭代器：ArrayBlockingQueue 提供了迭代器，允许在遍历队列的同时安全地访问队列中的元素。但需要注意的是，迭代器的弱一致性意味着它反映的元素状态可能有些滞后。
  • 实现
    • ReentrantLock
    • Condition
package chatpter06;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ArrayBlockingQueue;

public class TestArrayBlockingQueue {
    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<String> queue = new ArrayBlockingQueue<>(3); // 创建一个容量为3的队列

        // 生产者线程
        Thread producer = new Thread(() -> {
            try {
                for (int i = 0; i < 5; i++) {
                    String item = "Item " + i;
                    System.out.println("Produced: " + item);
                    queue.put(item); // 将元素放入队列，如果队列满则阻塞
                    Thread.sleep(1000); // 模拟耗时操作
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });

        // 消费者线程
        Thread consumer = new Thread(() -> {
            try {
                while (true) {
                    String item = queue.take(); // 从队列中取出元素，如果队列空则阻塞
                    System.out.println("Consumed: " + item);
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });

        // 启动线程
        producer.start();
        consumer.start();
    }
}

在这里插入图片描述

3、LinkedBlockingQueue

  • 基于链表，无界的FIFO阻塞队列。LinkedBlockingQueue对于添加和删除元素分别采用了独立的锁来控制数据同步，这也意味着在高并发的情况下生产者和消费者可以并行地操作队列中的数据，以此来提高整个队列的并发性能
  • 需要注意的是，在新建一个LinkedBlockingQueue对象时，若没有指定其容量大小，则LinkedBLockingQueue会默认一个类似无限大小的容量（Integer.MAX_VALUE），这样的话，如果生产者的速度一旦大于消费者的速度，也许还没有等到队列满阻塞生产，系统内存就有可能已被消耗殆尽。
  • 主要特点和功能：
    • 阻塞操作：当队列为空时，从队列中获取元素的线程将会被阻塞，直到有元素可获取；当队列已满时，尝试添加元素的线程将会被阻塞，直到队列中有空间可用。
    • 可选容量：在创建 LinkedBlockingQueue 时，可以指定一个容量限制。如果不指定容量，那么 LinkedBlockingQueue 的默认容量为 Integer.MAX_VALUE。
    • 线程安全：LinkedBlockingQueue 的所有公共方法都是线程安全的，可以在多线程环境下安全使用。
    • 性能：相比于 ArrayBlockingQueue，LinkedBlockingQueue 在插入和删除操作上有更好的性能，因为它内部是通过链表实现的，而链表在动态调整大小方面比数组更灵活。
package chatpter06;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class TestLinkedBlockingQueue {
    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<String> queue = new LinkedBlockingQueue<>(3); // 创建一个容量为3的队列

        // 生产者线程
        Thread producer = new Thread(() -> {
            try {
                for (int i = 0; i < 5; i++) {
                    String item = "Item " + i;
                    System.out.println("Produced: " + item);
                    queue.put(item); // 将元素放入队列，如果队列满则阻塞
                    Thread.sleep(1000); // 模拟耗时操作
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });

        // 消费者线程
        Thread consumer = new Thread(() -> {
            try {
                while (true) {
                    String item = queue.take(); // 从队列中取出元素，如果队列空则阻塞
                    System.out.println("Consumed: " + item);
                    Thread.sleep(100000);
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        });

        // 启动线程
        producer.start();
        consumer.start();
    }
}

在这个示例中，我们创建了一个容量为3的 LinkedBlockingQueue，并启动了一个生产者线程和一个消费者线程。生产者线程不断生产元素并放入队列，消费者线程从队列中取出元素并消费。由于队列的容量限制，当队列满时，生产者线程会被阻塞，直到队列中有空间可用；当队列空时，消费者线程会被阻塞，直到队列中有元素可消费。

4、PriorityBlockingQueue

  • 支持优先级的无界阻塞队列，PriorityBlockQueue并不会阻塞数据生产者，而只会在没有可消费的数据时，阻塞数据的消费者。在使用的时候要特别注意，生产者生产数据的速度绝对不能快于消费者消费数据的速度，否则时间一长，会最终消耗所有的可用堆内存空间。
  • 默认情况下元素采用自然顺序升序排序，可以通过指定Comparetor来对元素进行排序
  • 二叉堆
    • 分类
      • 最大堆
        父节点的键值总是大于或等于任何一个子节点的键值
      • 最小堆
        父节点的键值总是小于或等于任何一个子节点的键值
        添加操作则是不断“上冒”，而删除操作则是不断“下掉”
  • 实现
    ReentrantLock + Condition
  • 二叉堆

5、LinkedTransferQueue

LinkedTransferQueue是Java并发包java.util.concurrent中的一个类，它实现了TransferQueue接口。这个队列是一个由链表结构组成的无界阻塞队列，具有先进先出（FIFO）的特性。它可以看作是LinkedBlockingQueue和SynchronousQueue的结合体。

LinkedTransferQueue提供了几个重要的方法，如transfer(E e)和tryTransfer(E e)，这些方法使得线程间的数据传递更为高效。具体来说：

transfer(E e)方法：如果当前存在一个正在等待获取的消费者线程，该方法会立刻将元素e移交给它；否则，它会将当前元素e插入到队列的尾部，并等待进入阻塞状态，直到有消费者线程取走该元素。
tryTransfer(E e)方法：如果当前存在一个正在等待获取的消费者线程（使用take()或poll()函数），该方法会即刻转移/传输对象元素e；如果不存在，则返回false，并且不进入队列。
此外，LinkedTransferQueue的实现在逻辑上与TransferStack（SynchronousQueue中的一个组件）大致相同，但由于队列是FIFO的，所以在匹配和入队操作上有所不同。每次匹配操作都是从头节点开始寻找，直到找到一个未匹配的节点，而入队列的节点是从队尾进入，与队头不冲突。

总的来说，LinkedTransferQueue是一个功能强大的并发队列，它提供了高效的线程间数据传递机制，适用于需要高效数据交换的并发场景。

6、SynchrousQueue

  • 一个没有容量的阻塞队列
  • 应用
    交换工作，生产者的线程和消费者的线程同步已传递某些信息、事件后者任务

7、DelayQueue

  • 支持延时获取元素的无界阻塞队列
  • 应用
    • 缓存：清掉缓存中超时的缓存数据
    • 任务超时处理
  • 实现
    • ReentrantLock + Condition
    • 根据Delay事件排序的有线级队列：PriorityQueue
  • Delayed接口
  • 用来标记那些应该在给定延迟时间之后执行的对象
  • 该接口要求实现它的实现类必须定义一个compareTo方法，该方法提供与此接口的getDelay方法一致的排序

标签：元素,Java,Thread,队列,编程,LinkedBlockingQueue,阻塞,线程
From： https://blog.csdn.net/yuming226/article/details/136997765

相关文章

  • Java实现轮询调度算法（Round Robin）
    Java实现轮询调度算法（RoundRobin）Java实现轮询调度算法（RoundRobin）引言在计算机科学中，轮询调度算法（RoundRobin）是一种常见的任务调度算法。它被广泛应用于操作系统、网络路由器、负载均衡器等领域。本文将介绍轮询调度算法的原理、实现以及在Java中的应用。轮询调度算法原理......
  • Java并发编程学习
    1.4wait()与notify例如消息队列生成和消费消息时候，可以用 wait(), notify通知对方wait和notify必须在synchronized方法里。1) wait释放当前线程的锁，线程进入等待状态，直到其他线程调用该对象的notify2)notify其他随机一个线程对应的等待状态解除。可以竞争当......
  • 【08每天十分钟，javase基础全搞定-秒懂参数传递问题上】
    参数传递问题基本类型按值传递引用类型按照内存地址进行传递。基本类型按值传递publicclassStudent{publicstaticvoidmain(String[]args){inta=10;tese(a);//相当于把10作为参数给了tese这个方法。System.out.println(a);//输......
  • 【白嫖无废话-秒懂javascript基础知识-免费持续更新】
    一、js须知的概念js是一门事件驱动型的编程语言，依靠事件去驱动，然后执行对应的程序。（一）JS中的事件在JS中有很多事件，其中有一个事件叫做：鼠标单击，单词：click。并且任何事件都会对应一个事件句柄叫做：onclick。注意：事件和事件句柄的区别是事件句柄是事件单词前加on而且事件......
  • 基于java的少儿编程网上报名系统—论文
    少儿编程网上报名系统的开发过程中，采用B/S架构，主要使用java技术进行开发，中间件服务器是Tomcat服务器，使用Mysql数据库和Eclipse开发环境。该少儿编程网上报名系统包括用户和管理员。其主要功能包括管理员：首页、个人中心、用户管理、课程类型管理、课程信息管理、课程购买管理......
  • 【05每天十分钟，javase基础全搞定-构造方法】
    构造方法格式：[修饰符]类名(形参列表){}构造方法也叫构造器，用于对象的初始化。构造器的名称应与它所在的类的名称一致构造方法的返回值跟普通方法有区别，普通方法的那种返回值，构造方法没有，也不能用void修饰符构造方法通过new关键字调用！构造方法的返回值类型是这个类本身。（......
  • JavaScript初识及基本语法详解
    JavaScript是一种轻量级的编程语言，它可以在网页中嵌入，用来控制网页的动态效果和用户交互。JavaScript是所有现代网页浏览器都支持的脚本语言，它可以让网页变得“活”起来，实现各种复杂的功能。JavaScript的基本语法JavaScript的语法基础与Java语言类似，但它是解释型语言，不需......
  • Java String类深入了解JDK各个版本进阶版本
    JavaString类深入了解JDK各个版本进阶版本一，底层类型在jdk11中Stringvalue存储字符串值是byte[]数组，String中存储字节码的是coder也是byte类型，因此String的底层数据存储类型成为了byte类型而在jdk8中String的Stringvalue存储字符串值是char[]数组，因此因此可......
  • Java版商城：Spring Cloud+SpringBoot b2b2c实现多商家入驻直播带货及 免 费 小程序商城
    随着互联网的快速发展，越来越多的企业开始注重数字化转型，以提升自身的竞争力和运营效率。在这个背景下，鸿鹄云商SAAS云产品应运而生，为企业提供了一种简单、高效、安全的数字化解决方案。鸿鹄云商SAAS云产品是一种基于云计算的软件服务，旨在帮助企业实现业务流程的自动化和优化。......
  • Java版企业电子招投标系统源代码，支持二次开发，采用Spring cloud技术
     在数字化时代，采购管理也正经历着前所未有的变革。全过程数字化采购管理成为了企业追求高效、透明和规范的关键。该系统通过SpringCloud、SpringBoot2、Mybatis等先进技术，打造了从供应商管理到采购招投标、采购合同、采购执行的全过程数字化管理。通过待办消息、招标公告、......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99