传统生产者和消费者问题，Sychronized版和Lock版

news2024/11/26 4:54:35

1.生产者和消费者问题Synchronized版

面试：单例模式、排序算法、生产者消费者、死锁

package com.kuang.pc;

/**
 * 线程之间的通信问题，生产者和消费者问题！ 等待唤醒 ，通知唤醒
 * 线程交替执行 A B 操作同一个变量 num=0
 * A num+1;
 * B num-1;
 */
public class A {

    public static void main(String[] args) {
        Data data = new Data();
        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                try {
                    data.increment();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"A").start();
        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                try {
                    data.decrement();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"B").start();

    }

}
// 判断等待，业务，通知
class Data{//数字  资源类
    private  int num = 0;

    //+1
    public synchronized void increment() throws InterruptedException {
       if(num!=0){
           //等待
           this.wait();
       }
       num++;
       //通知其他线程，我+1完毕了
        System.out.println(Thread.currentThread().getName()+"=>"+num);
        this.notifyAll();
    }

    //+1
    public synchronized void decrement() throws InterruptedException {
        if(num==0){
            //等待
            this.wait();
        }
        num--;
        //通知其他线程，我-1完毕了
        System.out.println(Thread.currentThread().getName()+"=>"+num);
        this.notifyAll();
    }

}

问题A B C D 开四个线程跑，在if判断之后被唤醒，没判断条件被执行了两次增加，导致的虚假唤醒问题。 

package com.kuang.pc;

/**
 * 线程之间的通信问题，生产者和消费者问题！ 等待唤醒 ，通知唤醒
 * 线程交替执行 A B 操作同一个变量 num=0
 * A num+1;
 * B num-1;
 */
public class A {

    public static void main(String[] args) {
        Data data = new Data();
        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                try {
                    data.increment();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"A").start();
        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                try {
                    data.decrement();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"B").start();


        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                try {
                    data.increment();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"C").start();

        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                try {
                    data.decrement();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"D").start();
    }

}
// 判断等待，业务，通知
class Data{//数字  资源类
    private  int num = 0;

    //+1
    public synchronized void increment() throws InterruptedException {
       while (num!=0){
           //等待
           this.wait();
       }
       num++;
       //通知其他线程，我+1完毕了
        System.out.println(Thread.currentThread().getName()+"=>"+num);
        this.notifyAll();
    }

    //+1
    public synchronized void decrement() throws InterruptedException {
       while (num==0){
            //等待
            this.wait();
        }
        num--;
        //通知其他线程，我-1完毕了
        System.out.println(Thread.currentThread().getName()+"=>"+num);
        this.notifyAll();
    }

}

 

2.新版Lock锁解决消费者生产者问题。 

 

package com.kuang.pc;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 * 线程之间的通信问题，生产者和消费者问题！ 等待唤醒 ，通知唤醒
 * 线程交替执行 A B 操作同一个变量 num=0
 * A num+1;
 * B num-1;
 */
public class B {

    public static void main(String[] args) {
        Data1 data = new Data1();
        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                try {
                    data.increment();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"A").start();
        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                try {
                    data.decrement();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"B").start();


        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                try {
                    data.increment();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"C").start();

        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                try {
                    data.decrement();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"D").start();
    }

    }

    
// 判断等待，业务，通知
class Data1 {//数字  资源类
    private int num = 0;

    Lock lock=new ReentrantLock();
    Condition condition = lock.newCondition();
//        condition.await();等待
//        condition.signalAll();唤醒全部
    //+1
    public void increment() throws InterruptedException {
        lock.lock();
        try {
          //业务代码
            while (num != 0) {
                //等待
                condition.await();
            }
            num++;
            System.out.println(Thread.currentThread().getName() + "=>" + num);
            //通知其他线程，我+1完毕了
            condition.signalAll();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }


    }

    //+1
    public void decrement() throws InterruptedException {
        lock.lock();
        try {
            //业务代码
            while (num == 0) {
                //等待
                condition.await();
            }
            num--;
            System.out.println(Thread.currentThread().getName() + "=>" + num);
            //通知其他线程，我-1完毕了
            condition.signalAll();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }


    }

}

任何一个新的技术，绝对不是仅仅只覆盖了原来的技术，优势，和补充！

Condition 优势精准通知，唤醒线程

package com.kuang.pc;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 * 线程之间的通信问题，生产者和消费者问题！ 等待唤醒 ，通知唤醒
 * 线程交替执行 A B 操作同一个变量 num=0
 * A num+1;
 * B num-1;
 */
public class C {

    public static void main(String[] args) {
        Data2 data = new Data2();

        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                data.printA();
            }
        },"A").start();
        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                data.printB();
            }
        },"B").start();
        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                data.printC();
            }
        },"C").start();


    }

}
// 判断等待，业务，通知
class Data2 {//数字  资源类


    private Lock lock=new ReentrantLock();
    private Condition condition1 = lock.newCondition();
    private Condition condition2 = lock.newCondition();
    private Condition condition3 = lock.newCondition();

    private int num=1;
    public void printA(){
        lock.lock();
        try {
            if (num!=1){
                //等待
                condition1.await();
            }
            num=2;
            System.out.println(Thread.currentThread().getName()+":Aaa");
         //唤醒，唤醒指定的人，B
           condition2.signal();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }


    }
    public void printB(){
        lock.lock();
        try {
            if (num!=2){
                condition2.await();
            }
            num=3;
            System.out.println(Thread.currentThread().getName()+":Bbb");
            condition3.signal();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }

    }
    public void printC(){
        lock.lock();
        try {
            if (num!=3){
                condition3.await();
            }
            System.out.println(Thread.currentThread().getName()+":Ccc");
            num=1;
            condition1.signal();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }

    }

}

精准唤醒线程  Condition

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

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

相关文章

无涯教程-JavaScript - ASINH函数

无涯教程-JavaScript - ASINH函数

描述 ASINH函数返回数字的反双曲正弦值。反双曲正弦是其双曲正弦为number的值,即ASINH(SINH(number))等于number。 语法 ASINH (number)争论 Argument描述Required/OptionalNumberAny real number.Required Notes 如果指定的数字未被识别为数字值,则ASIN返回#VALUE!错误 …
阅读更多...
想要精通算法和SQL的成长之路 - 填充书架

想要精通算法和SQL的成长之路 - 填充书架

想要精通算法和SQL的成长之路 - 填充书架 前言一. 填充书架1.1 优化 前言 想要精通算法和SQL的成长之路 - 系列导航 一. 填充书架 原题链接 题目中有一个值得注意的点就是&#xff1a; 需要按照书本顺序摆放。每一层当中&#xff0c;只要厚度不够了&#xff0c;当前层最高…
阅读更多...
Chatbase：AI客服聊天机器人工具

Chatbase：AI客服聊天机器人工具

【产品介绍】 名称 Chatbase.co 具体描述 Chatbase.co 是一个智能的聊天机器人平台&#xff0c;它可以帮助用户快速地构建、部署和分析用户的聊天机器人&#xff0c;无论 用户是一个初学者还是一个专家。用户可以使用 Chatbase.co …
阅读更多...
什么是边缘计算网关？

什么是边缘计算网关？

边缘计算网关&#xff08;简称 边缘网关&#xff09;将云端功能扩展到本地的边缘设备&#xff0c;使边缘设备能够快速自主地响应本地事件&#xff0c;提供低延时、低成本、隐私安全、本地自治的本地计算服务。 同时所有服务都以 Docker 镜像方式安装&#xff0c;真正做到了跨平…
阅读更多...
基础算法---离散化

基础算法---离散化

概念 离散化&#xff0c;把无限空间中有限的个体映射到有限的空间中去&#xff0c;以此提高算法的时空效率。 通俗的说&#xff0c;离散化是在不改变数据相对大小的条件下&#xff0c;对数据进行相应的缩小。 也就是说当数据空间跨越太大,但是数据的个数却不多,我们可以使用…
阅读更多...
Linux命令-文件展示

Linux命令-文件展示

1、ls、ll命令——展示数据 ①ls命令——平铺展示数据 其中ls命令以平铺的方式展现数据 ②ll命令——列表展示数据 ll命令以列表的方式展现数据 -a选项&#xff0c;表示&#xff1a;all的意思&#xff0c;即列出全部文件&#xff08;包含隐藏的文件/文件夹&#xff09; -l选项…
阅读更多...
Linux centos7 bash编程训练

Linux centos7 bash编程训练

训练编写一段代码&#xff0c;打印输出100之内的明7暗7&#xff0c;同时要求每5个数字打印在一行。 此项训练主要是考察for循环的使用&#xff0c;及条件判断表达式的设置和不同写法的应用。 常用的for循环有四种写法&#xff08;如打印1-100的整数&#xff09;&#xff1a; …
阅读更多...
数据优化与可视化：3D开发工具HOOPS在BIM模型轻量化中的作用分析

数据优化与可视化：3D开发工具HOOPS在BIM模型轻量化中的作用分析

在建筑和工程领域&#xff0c;BIM&#xff08;建筑信息建模&#xff09;是一种重要的数字化工具&#xff0c;但大型BIM模型往往需要大量的计算资源和存储空间。为了解决这一问题&#xff0c;HOOPS技术成为了一种关键工具&#xff0c;可以帮助实现BIM模型轻量化&#xff0c;提高…
阅读更多...
docker 已经配置了国内镜像源，但是拉取镜像速度还是很慢（gcr.io、quay.io、ghcr.io）

docker 已经配置了国内镜像源，但是拉取镜像速度还是很慢（gcr.io、quay.io、ghcr.io）

前言 国内用户在使用 docker 时&#xff0c;想必都遇到过镜像拉取慢的问题&#xff0c;那是因为 docker 默认指向的镜像下载地址是 https://hub.docker.com&#xff0c;服务器在国外。 网上有关配置 docker 国内镜像源的教程很多&#xff0c;像 腾讯、阿里、网易 等等都会提供…
阅读更多...
NVR添加rtsp流模拟GB28181视频通道

NVR添加rtsp流模拟GB28181视频通道

一、海康、大华监控摄像头和硬盘录像机接入GB28181平台配置 1、海康设备接入配置 通过web登录NVR管理系统&#xff0c;进入网络&#xff0c;高级配置界面&#xff0c;填入GB28181相关参数。 将对应项按刚才获取的配置信息填入即可&#xff0c;下面的视频通道的编码ID可以保持…
阅读更多...
类和对象三大特性之继承

类和对象三大特性之继承

全文目录 继承的概念定义格式继承关系和访问限定符final 基类和派生类对象赋值转换继承中的作用域派生类的六个默认成员函数构造函数拷贝构造函数operator析构函数 友元和静态成员友元静态成员 各种继承形式菱形继承虚继承菱形虚拟继承对象模型 继承和组合 继承的概念 通过继承…
阅读更多...
PyTorch深度学习（二）【反向传播、用pytorch实现线性回归】

PyTorch深度学习（二）【反向传播、用pytorch实现线性回归】

反向传播 弄一个简单点的&#xff0c;两层的神经网络: 加入激活函数&#xff1a;&#xff08;不加激活函数的神经网络就是一个线性回归模型&#xff09; 用到的损失函数&#xff1a; pytorch里面的数据存储&#xff1a;tensor&#xff0c;它可以存标量、向量、矩阵、高维度数据…
阅读更多...
帝国EmpireCMS_7.5_SC_UTF8漏洞复现

帝国EmpireCMS_7.5_SC_UTF8漏洞复现

一、漏洞说明 EmpireCMS 7.5版本及之前版本在后台备份数据库时&#xff0c;未对数据库表名做验证&#xff0c;通过修改数据库表名 二、搭建环境 下载地址&#xff1a;http://www.phome.net/download/ 然后执行&#xff1a;http://127.0.0.1/EmpireCMS_7.5_SC_UTF8/upload/e/ins…
阅读更多...
基于Levenberg-Marquardt算法的声源定位matlab仿真

基于Levenberg-Marquardt算法的声源定位matlab仿真

目录 1.算法运行效果图预览 2.算法运行软件版本 3.部分核心程序 4.算法理论概述 5.算法完整程序工程 1.算法运行效果图预览 2.算法运行软件版本 matlab2022a 3.部分核心程序 .................................................................... %ML if (bML1)varxs…
阅读更多...
XGBoost实战2--数据预测保险赔偿

XGBoost实战2--数据预测保险赔偿

一、概述 本次实战基于给出的数据进行保险预测。数据集&#xff1a;Allstate Claims Severity | Kaggle 给出的训练数据是116列&#xff08;cat1-cat116&#xff09;的离散数据和14列&#xff08;con1-con14&#xff09;的连续数据。数据集中的每一行表示一个保险索赔。必须预…
阅读更多...
Jina AI @Slush 上海 地表最酷科技创新大会来啦！

Jina AI @Slush 上海 地表最酷科技创新大会来啦！

地表最酷的科技创新大会 S 创上海 2023 The Final Slush Shanghai 即将在 9 月 22 - 23 日空降上海 Jina AI 受邀参与本次大会&#xff0c;并带来好玩的互动&#xff01; 多种门票限时限量派送中 还在犹豫什么&#xff01;&#xff01; 就等你啦~ 什么是 S 创 2023 上海大会 本…
阅读更多...
vulnhub靶机Thoth-Tech

vulnhub靶机Thoth-Tech

下载地址&#xff1a;https://download.vulnhub.com/thothtech/Thoth-Tech.ova 主机发现 arp-scan -l 目标&#xff1a;192.168.21.148 端口扫描 nmap --min-rate 10000 -p- 192.168.21.148 服务扫描 nmap -sV -sT -O -p21,22,80 192.168.21.148 漏洞扫描 nmap --scriptvu…
阅读更多...
IT技术2222

IT技术2222

发布的方式 脚本 ansible 自动化&#xff0c;点点点
阅读更多...
Mac电脑报错“托管配置文件格式不正确”的解决方法

Mac电脑报错“托管配置文件格式不正确”的解决方法

本文介绍在Mac电脑中&#xff0c;复制地址链接后出现“托管配置文件格式不正确”这一报错的解决方法。 有时候&#xff0c;我们在把订阅地址粘贴到对应软件中时&#xff0c;会出现托管配置文件格式不正确: invalid mode: redir-host的报错。 出现这种报错&#xff0c;就意味着我…
阅读更多...
座舱台架介绍与搭建流程

座舱台架介绍与搭建流程

座舱台架介绍 车载测试中的座舱台架测试包括以下几个方面&#xff1a; 仪表盘&#xff1a;测试仪表盘的显示、功能、光线反射和防眩目性能等。评估仪表盘是否能够提供准确的驾驶信息&#xff0c;并能在各种光照条件下清晰可见。中控屏&#xff1a;测试中控屏的触摸响应、图像…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023