多线程-生产者消费者模型

news2024/11/10 16:24:54

一、基本信息

1、场景介绍:厨师和吃货的例子,吃货吃桌子上的面条,吃完让厨师做,厨师做完面条放桌子上,让吃货吃,厨师如果发现桌子上有面条,就不做,吃货发现桌子上没有面条就不吃。

2、线程实现基本步骤:

  1. 循环
  2. 同步代码块
  3. 循环退出条件
  4. 循环没有退出时,业务代码的实现

二、代码实现 

桌子类:

public class Desk {
    //食物状态
    public static int status = 0;
    //锁
    public static Object lock = new Object();
    //面条剩余数量
    public static int count = 5;
}

厨师类:

/**
 * 厨师做饭线程
 */
public class Cookie extends Thread{
    /**
     * 多线线程实现的基本步骤:
     * 1、循环
     * 2、同步代码块
     * 3、循环的退出条件
     * 4、未退出时的业务代码逻辑
     */

    /**
     * 厨师的业务逻辑
     * 1、判断桌子上有没有面条
     * 2、有面条就等待;没有面条就做面条,并且唤醒等待的吃货吃面条
     */

    @Override
    public void run() {
        while (true){
            synchronized (Desk.lock){
                //判断面条数量
                if (Desk.count == 0) {
                    break;
                }
                //判断桌子上是否有面条
                if (Desk.status == 1){
                    //有面条时,就等待
                    //这里需要用锁对象调用等待方法,目的是为了绑定锁和线程
                    try {
                        Desk.lock.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }else {
                    //没有面条就要做面条
                    System.out.println(getName() + "做了一碗面条");
                    //改状态,表示面条做好了
                    Desk.status = 1;
                    //唤醒吃货吃面条
                    Desk.lock.notifyAll();
                }
            }
        }
    }
}

吃货类:

/**
 * 吃货
 */
public class Foodie extends Thread {
    /**
     * 多线线程实现的基本步骤:
     * 1、循环
     * 2、同步代码块
     * 3、循环的退出条件
     * 4、未退出时的业务代码逻辑
     */

    /**
     * 吃货的业务逻辑
     * 1、判断桌子上有没有面条
     * 2、有面条就吃;没有面条就等待,并且唤醒等待的厨师做面条
     */
    @Override
    public void run() {
        while (true) {
            synchronized (Desk.lock) {
                //判断面条数量
                if (Desk.count == 0) {
                    break;
                } else {
                    //判断桌子上是否有面条
                    if (Desk.status == 1) {
                        Desk.count--;
                        System.out.println(getName() + "吃了一碗面条");
                        System.out.println(getName() + "还能吃" + Desk.count + "碗面条");
                        Desk.status = 0;
                        Desk.lock.notifyAll();
                    }else {
                        try {
                            Desk.lock.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
            }
        }
    }
}

 测试类:

public class TestCookie {
    public static void main(String[] args) {
        Cookie cookie = new Cookie();
        Foodie foodie = new Foodie();

        cookie.setName("厨师");
        foodie.setName("吃货");

        cookie.start();
        foodie.start();
    }
}

运行结果:

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1366282.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

UE5 C++(十三)— 创建Character,添加增强输入

文章目录 创建Character第三人称模板添加增强输入引用在脚本中实现移动、旋转 创建Character第三人称模板 创建MyCharacter C类 添加增强输入引用 在DEMO.Build.cs 脚本中添加增强输入模块 有个容易出错的点,这里的设置一定要正确 然后添加引用到C头文件中 …

vim/vi 模式切换和常用快捷键

vim/vi 切换模式: vim/vi 常用快捷键: 一般模式: gg:文件开头、G:文件结尾 shift^ :光标当前行首、shift^:光标当前行尾 yy:复制、p:粘贴、dd:删除当前行、…

VScode右键没有go to definition选项

1. 背景 1.1. 项目代码在远程服务器上; 1.2. win重装系统,重新安装vscode出现问题,没重装系统之前是没问题的; 2. 问题 打开vscode,通过ssh链接远程服务器中的项目代码后,选中函数右键没有go to defini…

年底了,来看看测试大佬的年终项目总结吧!值得借鉴

测试总结,是测试负责人或测试经理的测试管理能力的体现。在项目或版本测试完成,测试报告上交后,测试的工作并不是完结了,而是另外一件大事需要做,那就是为这个项目或是版本做一次测试总结。 添加图片注释,不…

10本审稿及出版效率均较好的科普期刊参数分享!

医、药、护、技及医学工程等相关的人员,进行卫生高级职称评审时,需要在专业期刊上公开发表本专业学术论文,论文的方向、内容质量以及发表的刊物都至关重要。今天常笑医学给大家整理了10本审稿及出版效率均较好的科普期刊!参数分享…

搭建React开发环境-webpack实现

周末在家学会React前端知识,记录下来,方便备查。 webpack版本:webpack5 编译器:vscode 第一步、新建项目及初始化 1)新建项目文件夹 可命名为 my_webpack 2)初始化项目 使用命令 npm init -y,…

[SpringBoot]接口的多实现:选择性注入SpringBoot接口的实现类

最近在项目中遇到两种情况,准备写个博客记录一下。 情况说明:Service层一个接口是否可以存在多个具体实现,此时应该如何调用Service(的具体实现)? 其实之前的项目中也遇到过这种情况,只不过我采…

CTF之逆向入门

逆向工程(Reverse Engineering),又称反向工程,是一种技术过程,即对一项目标产品进行逆向分析及研究,从而演绎并得出该产品的处理流程、组织结构、功能性能规格等设计要素,以制作出功能相近,但又不完全一样的…

微信私密朋友圈被吐槽有BUG

日前,大量网友在各社交媒体上讨论微信私密朋友圈出现 Bug 的话题,起因是跨年期间一个网友发布了一条”私密朋友圈,但不一会就收到朋友发来的信息,”又偷偷发朋友圈了?“,估计此时网友可能已经”寒毛四起、汗…

物理机搭建hive

一、修改Hadoop配置 修改core-site.xml 配置yarn-site.xml 分发文件,然后重启集群 二、 Hive解压安装 上传文件 添加hive环境便量,source生效 启动高可用集群,启动hive 三、配置mysql元数据库 检查当前系统是否安装过Mysql&#xf…

基于MATLAB车牌识别系统设计

基于MATLAB车牌识别系统设计 一、设计方案 智能交通系统已成为现代社会道路交通发展趋势。在智能交通系统中,车牌自动识别系统是一个非常重要的发展方向。对于车牌识别系统的要满足当车辆通过摄像头采集车辆图片,将其图片进行图像预处理、车牌定位、字符…

关于FPGA仿真复位信号和实际板子复位信号的吐血大坑

最近在研究mipi dphy IP下载到板子上进行验证的初步流程问题 IP的example案例里面,系统复位全是高电平复位,低电平工作 想当然的打通IP流程,写工程的时候也使用了高电平复位,低电平复位 结果调试了N轮,init_done信号一…

通用web自动扩缩容_智能运维引擎CudgX

一、概述 CudgX是星汉未来自主研发的面向云原生时代的智能运维引擎,支持根据 MetricQPS 分段耗时指标进行自动扩缩容。 通过各类服务的多维度、大规模的日志数据采集以及机器学习训练分析,对服务进行数字化、指标化度量,并基于部署的…

基础算法【解题思路】:单链表的倒数第k个节点

定义指针p1,让p1走k步: 定义指针p2,在p1走了k步的时候,p2也跟着走。 p1走到最后的时候走了n-k步,停留在最后的null结点。 P2从头结点开始,也跟着走到了n-k步,而n-k恰好是倒数第k个节点。 例…

TypeScript 从入门到进阶之基础篇(六) 类型(断言 、推论、别名)| 联合类型 | 交叉类型

系列文章目录 TypeScript 从入门到进阶系列 TypeScript 从入门到进阶之基础篇(一) ts基础类型篇TypeScript 从入门到进阶之基础篇(二) ts进阶类型篇TypeScript 从入门到进阶之基础篇(三) 元组类型篇TypeScript 从入门到进阶之基础篇(四) symbol类型篇TypeScript 从入门到进阶…

css - 渐变样式实现(渐变边框 + 渐变背景)

.select {border-bottom: 2px solid; /* 下边框 */border-image: linear-gradient(90deg,rgba(250, 173, 20, 0) 0%,rgba(250, 173, 20, 1) 51.46%,rgba(125, 87, 10, 0) 100%)1; /* 边框渐变 */background-image: radial-gradient(circle at 49% 238%, #faad14, transparent 7…

2023APMCM亚太数学建模C题 - 中国新能源汽车的发展趋势(2)

五.问题二模型建立和求解 5.1 问题二模型建立和求解 针对题目二,题目要求收集中国新能源电动汽车行业发展数据,建立数学模型描述,并预测未来十年的发展。由于在第一文中,我们已经收集了一定的新能源行业发展数据&…

马尔可夫算法及其实例(预测类模型)

马尔科夫预测模型是一种基于马尔科夫过程的预测方法。马尔科夫过程是一类具有马尔科夫性质的随机过程,即未来的状态只依赖于当前状态,而与过去状态无关。这种过程通常用状态空间和状态转移概率矩阵来描述。 在马尔科夫预测模型中,系统被建模为…

提升工作效率:IDEA配置优化总结指南

idea 配置优化总结 配置优化优化性能优化JVM参数使用 jconsole 监控 full gc 频率关闭代码检查设置编译进程和Maven的堆值取消自动构建 修改快捷键System Settings个性化设置设置主题修改字体Color SchemeCode Style 包类设置设置maven自动导包显示pom依赖关系图,解…

【docker笔记】Docker网络

Docker网络 容器间的互联和通信以及端口映射 容器IP变动时候可以通过服务名直接网络通信而不受到影响 常用命令 查看网络 docker network ls创建网络 docker network create XXX网络名字查看网络源数据 docker network inspect XXX网络名字删除网络 docker network rm…