阻塞队列.

这篇具有很好参考价值的文章主要介绍了阻塞队列.。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

目录

♫什么是阻塞队列

♫什么是生产-消费者模式

♫实现一个阻塞队列

♫BlockingQueue


♫什么是阻塞队列

阻塞队列是一种特殊的队列,它除了具备队列的先进先出的特点外,还具有以下特点:

♩.如果队列为空时,执行出队列操作,会阻塞等待,直到另一个线程往队列里添加元素(队列不为空)

♩.如果队列满了时,执行入队列操作,会阻塞等待,直到另一个线程取出队列里的元素(队列没有满)

阻塞队列常用于实现生产者-消费者模式,通过控制队列的阻塞,使得生产者和消费者的协作更加有效和高效。下面我们先简单认识下生产者-消费者模式~

♫什么是生产-消费者模式

生产者消费者模式是一种常见的并发编程模式。该模式主要针对一个共享的缓冲区,多个生产者可以向缓冲区中添加数据,多个消费者可以从缓冲区中获取数据。在该模式中,生产者向缓冲区中添加数据,如果缓冲区已满,则生产者需要等待消费者消费完一部分数据后再向缓冲区添加数据;消费者从缓冲区中获取数据,如果缓冲区为空,则消费者需要等待生产者生产数据后再从缓冲区中获取数据。生产者和消费者之间通过缓冲区进行通信和协调,而缓冲区就可以由阻塞队列构成。

一个典型的生产者-消费者模式的例子是吃酒席的时候:后厨(生产者)端菜到餐桌(阻塞队列)上,宾客(消费者)从餐桌(阻塞队列)上取走事物食用,当餐桌放满了食物,后厨就要等宾客吃完一碟再上,当餐桌上没有食物,宾客就得等后厨上菜后再吃。

使用生产者-消费者模式有以下两点好处:

♩.有效降低生产者和消费者之间的耦合:生产者和消费者之间通过阻塞队列进行交互,彼此之间没有直接关联

♩.平衡生产者和消费者之间的速度差异:由于阻塞队列的特性,平衡了两者的速度差异,保证了系统的稳定性

♫实现一个阻塞队列

我们先通过数组,实现一个普通的循环队列:

public class MyBlockingQueue {
    private int[] items;
    private int head;
    private int tail;
    private int size;

    public MyBlockingQueue() {
        items = new int[1000];
        head = 0;
        tail = 0;
        //队列中元素的有效个数
        size = 0;
    }
    
    //入队列
    public void put(int value) {
        //队列满了
        if (size == items.length) {
            return;
        }
        //队列没满
        items[tail] = value;
        tail = (tail + 1) % items.length;
        size++;
    }
    
    //出队列
    public int take() {
        //队列为空
        if (size == 0) {
            return -1;
        }
        //队列不为空
        int value = items[head];
        head = (head + 1) % items.length;
        size--;
        return value;
    }
}

再对队列填加阻塞功能,并保证线程安全:

public class MyBlockingQueue {
    private int[] items;
    private int head;
    private int tail;
    private volatile int size;

    public MyBlockingQueue() {
        items = new int[1000];
        head = 0;
        tail = 0;
        //队列中元素的有效个数
        size = 0;
    }

    //入队列
    public void put(int value) throws InterruptedException {
        synchronized (this) {
            //队列满了
            // 此处最好使用 while,否则 notifyAll 的时候, 该线程从 wait 中被唤醒
            // 但是紧接着并未抢占到锁. 当锁被抢占的时候, 可能又已经队列满了,就只能继续等待
            while (size == items.length) {
                wait();
            }
            //队列没满
            items[tail] = value;
            tail = (tail + 1) % items.length;
            size++;
            notifyAll();
        }
    }

    //出队列
    public int take() throws InterruptedException {
        int value = 0;
        synchronized (this) {
            //队列为空
            // 此处最好使用 while,否则 notifyAll 的时候, 该线程从 wait 中被唤醒
            // 但是紧接着并未抢占到锁. 当锁被抢占的时候, 可能又已经队列满了,就只能继续等待
            while (size == 0) {
                wait();
            }
            //队列不为空
            value = items[head];
            head = (head + 1) % items.length;
            size--;
            notifyAll();
        }
        return value;
    }
}

♫BlockingQueue

阻塞队列.,java,开发语言

♩.BlockingQueue是concurrent包下的一个接口,是Java标准库中内置的阻塞队列。

♩.BlockingQueue除了保留Queue的offer、poll、peek方法外,还提供了带有阻塞功能的入队列方法:put()和带有阻塞功能的出队列方法:take()。

♩.BlockingQueue的实现类有:

①.LinkedBlockingQueue:基于链表实现的阻塞队列。

②.PriorityBlockingQueue:基于优先级队列(堆)实现的阻塞队列。③.ArrayBlockingQueue:基于数组实现的阻塞队列。

知道了BlockingQueue的基本信息,接下来我们来使用BlockingQueue实现一个生产者-消费者模式:

class Test {
    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<Integer> blockingQueue = new LinkedBlockingQueue<Integer>();
        Thread customer = new Thread(()->{
            while (true) {
                try {
                    int value = blockingQueue.take();
                    System.out.println("消费者:" + value);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
        });
        Thread producer = new Thread(()->{
            Random random = new Random();
            while (true) {
                try {
                    int value = random.nextInt(1000);
                    blockingQueue.put(value);
                    System.out.println("生产者:" + value);
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
        });
        customer.start();
        producer.start();
        customer.join();
        producer.join();
    }
}

由于在producer线程中sleep(100),所以producer线程入队列会很慢,producer线程一入队列就被customer线程取出:

阻塞队列.,java,开发语言

注:由于两个线程的输出语句是并行执行,故先打印生产者还是消费者是不确定的文章来源地址https://www.toymoban.com/news/detail-717239.html

到了这里,关于阻塞队列.的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • java高并发系列 - 第25天:掌握JUC中的阻塞队列

    这是java高并发系列第25篇文章。 环境:jdk1.8。 本文内容 掌握Queue、BlockingQueue接口中常用的方法 介绍6中阻塞队列,及相关场景示例 重点掌握4种常用的阻塞队列 Queue接口 队列是一种先进先出(FIFO)的数据结构,java中用Queue接口来表示队列。 Queue接口中定义了6个方法:

    2024年02月14日
    浏览(37)
  • 【Java】多线程案例(单例模式,阻塞队列,定时器,线程池)

    ❤️ Author: 老九 ☕️ 个人博客:老九的CSDN博客 🙏 个人名言:不可控之事 乐观面对 😍 系列专栏: 单例模式是设计模式之一。代码当中的某个类,只能有一个实例,不能有多个。单例模式分为:饿汉模式和懒汉模式 饿汉模式表示很着急,就想吃完饭剩下很多碗,然后一

    2024年02月06日
    浏览(43)
  • Java 多线程系列Ⅳ(单例模式+阻塞式队列+定时器+线程池)

    设计模式就是软件开发中的“棋谱”,软件开发中也有很多常见的 “问题场景”。针对这些问题场景,大佬们总结出了一些固定的套路。按照这些套路来实现代码可能不会很好,但至少不会很差。当前阶段我们需要掌握两种设计模式: (1)单例模式 (2)工厂模式 概念/特征

    2024年02月09日
    浏览(55)
  • 【Java系列】多线程案例学习——基于阻塞队列实现生产者消费者模型

    个人主页:兜里有颗棉花糖 欢迎 点赞👍 收藏✨ 留言✉ 加关注💓本文由 兜里有颗棉花糖 原创 收录于专栏【Java系列专栏】【JaveEE学习专栏】 本专栏旨在分享学习JavaEE的一点学习心得,欢迎大家在评论区交流讨论💌 什么是阻塞式队列(有两点): 第一点:当队列满的时候

    2024年02月04日
    浏览(52)
  • 【Java多线程】关于多线程的一些案例 —— 单例模式中的饿汉模式和懒汉模式以及阻塞队列

    目录 1、单例模式 1.1、饿汉模式 2.1、懒汉模式  2、阻塞队列 2.1、BlockingQueue 阻塞队列数据结构 对框架和设计模式的简单理解就是,这两者都是“大佬”设计出来的,让即使是一个代码写的不太好的“菜鸡程序员”也能写出还可以的代码。 设计模式也可以认为是对编程语言语

    2024年03月23日
    浏览(90)
  • Java - JUC(java.util.concurrent)包详解,其下的锁、安全集合类、线程池相关、线程创建相关和线程辅助类、阻塞队列

    JUC是java.util.concurrent包的简称,在Java5.0添加,目的就是为了更好的支持高并发任务。让开发者进行多线程编程时减少竞争条件和死锁的问题 java.lang.Thread.State tools(工具类):又叫信号量三组工具类,包含有 CountDownLatch(闭锁) 是一个同步辅助类,在完成一组正在其他线程中

    2024年02月05日
    浏览(34)
  • 微服务---Redis实用篇-黑马头条项目-优惠卷秒杀功能(使用java阻塞队列对秒杀进行异步优化)

    1.1 秒杀优化-异步秒杀思路 我们来回顾一下下单流程 当用户发起请求,此时会请求nginx,nginx会访问到tomcat,而tomcat中的程序,会进行串行操作,分成如下几个步骤 1、查询优惠卷 2、判断秒杀库存是否足够 3、查询订单 4、校验是否是一人一单 5、扣减库存 6、创建订单 在这六

    2024年02月05日
    浏览(50)
  • 【数据结构-队列】阻塞队列

    💝💝💝欢迎来到我的博客,很高兴能够在这里和您见面!希望您在这里可以感受到一份轻松愉快的氛围,不仅可以获得有趣的内容和知识,也可以畅所欲言、分享您的想法和见解。 推荐:kuan 的首页,持续学习,不断总结,共同进步,活到老学到老 导航 檀越剑指大厂系列:全面总

    2024年02月09日
    浏览(37)
  • 阻塞队列(消息队列)

    队列是一种先进先出的数据结构。而阻塞队列也是一种特殊的队列,也遵守”先进先出“的原则。 阻塞队列是一种线程安全的的数据结构,并且具有以下 特性 : 1、队列往进写元素是从队尾插入,队首取出 2、当插入元素的时候,先判断一下,队列是否已经满了,如果满了就

    2024年02月11日
    浏览(41)
  • 阻塞队列的原理及应用

    阻塞队列是一种常用的并发编程工具,它能够在多线程环境下提供一种安全而高效的数据传输机制。本文将介绍阻塞队列的原理和使用场景,并通过实例演示其在多线程编程中的应用。 阻塞队列是一种特殊的队列,它具有以下几个特点: 阻塞特性:当队列为空时,从队列中

    2024年02月10日
    浏览(33)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包