Java多线程二-线程安全

1、线程安全问题

        多个线程,同时操作同一个共享资源的时候,可能会出现业务安全问题。

2、实例:取钱的线程安全问题

2.1、场景

        小明和小红是夫妻,他们有个共同账户,余额是十万元,如果两人同时取钱并且各自取十万元,可能会出现什么问题?

2.2、模拟取钱案例

        分析:

        1、需要提供一个账户类,接着创建一个账户对象代表2个人的共享账户。

        2、需要定义一个线程类(用于创建两个线程,分别代表小明和小红)。

        3、创建2个线程,传入同一个账户对象给2个线程处理。

        4、启动两个线程,同时去同一个账户对象中取钱10万元。

public class ThreadTest {public static void main(String[] args) {//1、创建一个账户对象,代表两个人的共享账户Account acc = new Account("ICBC-110",1000000);//2、创建两个线程,分别代表小明、小红,再去同一个账户下取出10万元。new DrawThread(acc,"小明").start();//小明new DrawThread(acc,"小红").start();//小红}
}public class Account {private String cargId;//卡号private double money;//余额public Account() {}public Account(String cargId, double money) {this.cargId = cargId;this.money = money;}public void drawMoney(double i){//判断谁来取钱String name = Thread.currentThread().getName();//判断余额是否足够if (this.money>=i){System.out.println(name+"来取钱:"+i+"成功");this.money -= i;System.out.println(name+"来取钱后,"+"余额剩余:"+this.money);}else{System.out.println(name+"来取钱:余额不足");}}public String getCargId() {return cargId;}public void setCargId(String cargId) {this.cargId = cargId;}public double getMoney() {return money;}public void setMoney(double money) {this.money = money;}
}public class DrawThread extends Thread{private Account account;public DrawThread(Account a,String name) {super(name);this.account = a;}@Overridepublic void run() {//super.run();//取钱account.drawMoney(1000000);}
}//执行结果
小红来取钱:1000000.0成功
小明来取钱:1000000.0成功
小红来取钱后,余额剩余:0.0
小明来取钱后,余额剩余:-1000000.0

2.3、解决办法:线程同步

2.3.1、线程同步的思想

小明和小红都使用了取钱线程,两个线程同时执行了,就出现了都取成功,余额出现了负数。

2.3.2、线程同步的常见方案

加锁:每次只允许一个线程加锁,加锁后才能进入访问,访问完毕后自动解锁,然后其他线程才能再加锁进来。

加锁的三种方式:1、同步代码块;2、同步方法;3、Lock锁

 2.3.3、同步代码块

作用:把访问共享资源的核心代码给上锁,以此保证线程安全。

synchronized(同步锁){

        访问共享资源的核心代码

}

原理:每次只允许一个线程加锁后进入,执行完毕后自动解锁,其他线程才可以进来执行,执行过程还是加锁再解锁

ps:对于当前同时执行的线程来说,同步锁必须是同一把(同一个对象),否则会出现bug。

 //将主业务设置为同步代码块synchronized ("同步锁") {if (this.money>=i){System.out.println(name+"来取钱:"+i+"成功");this.money -= i;System.out.println(name+"来取钱后,"+"余额剩余:"+this.money);}else{System.out.println(name+"来取钱:余额不足");}}
//执行结果
小明来取钱:1000000.0成功
小明来取钱后,余额剩余:0.0
小红来取钱:余额不足

 如果有其他人来取钱

Account acc1 = new Account("ICBC-112",1000000);
new DrawThread(acc1,"小黑").start();//小黑
new DrawThread(acc1,"小白").start();//小白

此时就会出现这情况

小白来取钱:1000000.0成功
小白来取钱后,余额剩余:0.0
小红来取钱:1000000.0成功
小红来取钱后,余额剩余:0.0
小黑来取钱:余额不足
小明来取钱:余额不足

解决办法就是将synchronized里面的参数改为this

 //this代表共享资源synchronized (this) {if (this.money>=i){System.out.println(name+"来取钱:"+i+"成功");this.money -= i;System.out.println(name+"来取钱后,"+"余额剩余:"+this.money);}else{System.out.println(name+"来取钱:余额不足");}}

执行结果

小黑来取钱:1000000.0成功
小黑来取钱后,余额剩余:0.0
小明来取钱:1000000.0成功
小白来取钱:余额不足
小明来取钱后,余额剩余:0.0
小红来取钱:余额不足

扩展:静态方法

当静态方法使用同步锁的时候,可以直接使用类名来作为参数

public static void test(){synchronized (Account.class){}}

PS:使用规范:

  • 建议使用共享资源做为锁对象,对于实力方法建议使用this作为锁对象。
  • 对于静态方法建议使用字节码(类名.class)对象作为锁对象。

 2.3.4、同步方法

 作用:把访问共享资源的核心方法给上锁,以此来保证线程安全

修饰符 synchronized 返回值类型 方法名称(形参列表){

        操作共享资源的代码

 原理:每次只能一个线程进入,执行完毕以后自动解锁,其他线程才可以进来执行。

 //同步方法,内部包含thispublic synchronized void drawMoney(double i){//判断谁来取钱String name = Thread.currentThread().getName();//判断余额是否足够if (this.money>=i){System.out.println(name+"来取钱:"+i+"成功");this.money -= i;System.out.println(name+"来取钱后,"+"余额剩余:"+this.money);}else{System.out.println(name+"来取钱:余额不足");}}
//执行结果
小红来取钱:1000000.0成功
小红来取钱后,余额剩余:0.0
小明来取钱:余额不足

同步方法底层原理:

  • 同步方法其实底层也是有隐士锁对象的,只是锁的范围是整个方法代码。
  • 如果方法是实例方法:同步方法默认用this作为的锁对象。
  • 如果方法是静态方法:同步方法默认用类名.class作为的锁对象。

 2.3.5、同步代码块与同步方法比较

  • 范围上:同步代码块锁的范围更小,同步方法锁的范围更大,锁的范围越小,性能越好。
  • 可读性:同步方法更好

 2.3.6、Lock锁

  • 是JDK5开始提供的一个新的锁定操作,通过它可以创建出锁对象进行加锁和解锁,更灵活、更方便、更强大。
  • 是接口,不能直接实例化,可以采用他的实现类ReentrantLock来构建Lock锁对象。

//创建一个锁对象
private Lock lock = new ReentrantLock();//加锁lock.lock();//判断余额是否足够if (this.money>=i){System.out.println(name+"来取钱:"+i+"成功");this.money -= i;System.out.println(name+"来取钱后,"+"余额剩余:"+this.money);}else{System.out.println(name+"来取钱:余额不足");}//解锁lock.unlock();
//执行结果
小明来取钱:1000000.0成功
小明来取钱后,余额剩余:0.0
小红来取钱:余额不足

ps:注意

  • 创建的时候增加final,保证不可修改:private final Lock lock = new ReentrantLock();
  • 解锁最好放在finally中:
    //加锁lock.lock();//判断余额是否足够try {if (this.money>=i){System.out.println(name+"来取钱:"+i+"成功");this.money -= i;System.out.println(name+"来取钱后,"+"余额剩余:"+this.money);}else{System.out.println(name+"来取钱:余额不足");}} catch (Exception e) {throw new RuntimeException(e);} finally {//解锁lock.unlock();}

    这样的好处就是,如果出现错误,还能继续执行

构造器说明
public ReentrantLock()获得Lock锁的实现类对象
常用方法
方法名称说明
void lock()获得锁
void unlocak()释放锁

2.4、线程通信

        当多个线程共同操作共享资源时,线程间通过某种方式互相告知自己的状态,以相互协调,并避免无效的资源争夺。

2.4.1、常见模型

  • 生产者负责生产数据。
  • 消费者线程负责消费生产者生产的数据。
  • 注意:生产者生产完数据应该等待自己,通知消费者消费;消费者消费完数据也应该等待自己,通知生产者生产。

2.4.2、 案例

 

Object类的等待和唤醒方法:

方法名称说明
void wait()让当前线程等待并释放所占锁,直到令一个线程调用notify()方法或notifyAll()方法
void notify()唤醒正在等待的单个线程
void notifyAll()唤醒正在等待的所有线程

注意:上述方法应该使用当前同步锁对象进行调用

public class ThreadTest {public static void main(String[] args) {Desk desk = new Desk();//创建三个生产者线程new Thread(() ->{desk.put();},"生产者1").start();new Thread(() ->{desk.put();},"生产者2").start();new Thread(() ->{desk.put();},"生产者3").start();//创建两个消费者线程new Thread(() ->{while (true) {desk.get();}},"消费者1").start();new Thread(() ->{while (true) {desk.get();}},"消费者2").start();}
}public class Desk {private List<String> list = new ArrayList<>();//放1个包子的方法//三个生产者public synchronized void put() {String name = Thread.currentThread().getName();//判断是否有包子try {if (list.size() == 0){list.add(name + "做的肉包子");System.out.println(name + "做了一个肉包子");Thread.sleep(2000);//唤醒别人,等待自己//先唤醒,再等待this.notifyAll();this.wait();}else{//其他生产者进来,发现有包子,不做了//唤醒别人,等待自己//先唤醒,再等待this.notifyAll();this.wait();}} catch (Exception e) {e.printStackTrace();}}//取一个包子的方法//两个消费者public synchronized void get() {String name = Thread.currentThread().getName();try {if (list.size() == 1){//有包子,吃掉System.out.println(name + "吃了:"+list.get(0));//清空listlist.clear();Thread.sleep(1000);//唤醒别人,等待自己//先唤醒,再等待this.notifyAll();this.wait();}else{//没有包子//唤醒别人,等待自己//先唤醒,再等待this.notifyAll();this.wait();}} catch (Exception e) {e.printStackTrace();}}
}

执行结果

生产者1做了一个肉包子
消费者2吃了:生产者1做的肉包子
生产者3做了一个肉包子
消费者1吃了:生产者3做的肉包子

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

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

相关文章

vue3-10

动态路由与菜单 路由文件 a6router.ts import { createRouter, createWebHashHistory } from "vue-router"; import { useStorage } from "vueuse/core"; import { Route, Menu } from "../model/Model8080"; const clientRoutes [{path: &q…

nginx的一些命令

linux start nginx 开启 /usr/sbin/nginx&#xff08;直接启动&#xff09; nginx -s stop 停止 /usr/local/nginx/sbin/nginx -s stop nginx -s quit 安全停止&#xff0c;保存信息 nginx -s reload 当配置信息修改&#xff0c;需要重新载入这些配置时使用此命令 nginx -s re…

MATLAB|交叉折线图之间分色填充

目录 公众号 效果图 交叉折线图之间分色填充概念介绍 应用领域 优点 缺点

Linux内核--内存管理(二)物理内存分页机制

一、引言 二、物理内存模型 ------>2.1、平坦内存模型(Flat Memory Model) ------>2.2、对称多处理 SMP(Symmetric MultiProcessing) ------>2.3、非均衡访存模型 NUMA(Non-Uniform Memory Access) 三、节点、区域和页 ------>3.1、节点 ------>3.2、区域…

Python 安装mysqlclient 错误 无法打开包括文件: “mysql.h”: 解决方法

解决方案&#xff1a;python最新3.12.0不支持mysqlclient 请下载 python3.9.9 版本 高速下载地址CNPM Binaries Mirror 官方下载地址Welcome to Python.org 下载完成后将python添加到环境变量 pycharm 虚拟环境下的python版本切换到你刚才下载的3.9.9的python版本 Avai…

C#文件操作File类vsFileInfo类和Directory类vsDirectoryInfo类

目录 一、File类vsFileInfo类 1.File类 &#xff08;1&#xff09;示例源码 &#xff08;2&#xff09;生成效果 2.FileInfo类 &#xff08;1&#xff09;示例源码 &#xff08;2&#xff09;生成效果 二、 Directory类vsDirectoryInfo类 1.Directory类 &#xff08;…

FilterChain攻击解析及利用

文章目录 BASE64解码和编码原理浅析EncodingDecoding Filterchain构造&#xff08;原理阐述&#xff09;回顾死亡代码特性一&#xff08;双重去杂&#xff09;特性二&#xff08;粘合性&#xff09; 任意字符构造工具一工具二 实战例题[NSSRound#7 Team]brokenFilterChain&…

运维01:云计算

云计算的类型 分类&#xff1a;公有云、私有云、混合云 云计算的服务模式 服务模式分3种&#xff1a; ①IaaS&#xff08;Infrastructure as a Service&#xff09;&#xff1a;基础设施即服务 ②PaaS&#xff08;Platform as a Service&#xff09;&#xff1a;平台即服务…

Java并发编程

一、基础知识 1. 为什么要使用并发编程 提升多核CPU的利用率&#xff1a;一般来说一台主机上的会有多个CPU核心&#xff0c;我们可以创建多个线程&#xff0c;理论上讲操作系统可以将多个线程分配给不同的CPU去执行&#xff0c;每个CPU执行一个线程&#xff0c;这样就提高了CP…

Portraiture2024最新Photoshop磨皮插件更新啦

Portraiture是一款由Imagenomic公司研发的Photoshop磨皮插件。该插件以其优秀的磨皮效果&#xff0c;成为了众多摄影师和化妆师使用的首选插件。Portraiture主要用于影楼、婚纱、时尚摄影等各个领域。其主要特点是能够轻松地模拟人眼的视觉感受&#xff0c;自然地修饰人像照片。…

带头双向循环链表的实现

目录 认识带头双向循环链表 双向链表 循环链表 带头链表 带头双向循环链表 双向链表的优势和不足&#xff1a; 顺序表的优势和不足&#xff1a; 实现带头双向循环链表 创建带头双向循环链表 初始化 创建返回链表的头结点 打印链表 尾插 尾删 头插 头删 查找 在…

java小游戏之【王者荣耀】

首先创建一个新的Java项目命名为“王者荣耀”&#xff0c;并在src下创建两个包分别命名为“com.sxt"、”com.stx.beast",在相应的包中创建所需的类。 代码 package com.sxt;import javax.swing.*; import java.awt.*;public class Background extends GameObject {p…

android shape绘制半圆

<?xml version"1.0" encoding"utf-8"?><shape xmlns:android"http://schemas.android.com/apk/res/android"android:shape"rectangle"><sizeandroid:width"20dp"android:height"10dp" /><…

滑块验证码之模拟人工滑速

前言 代码直接运行即可 此处是用的selenium模拟&#xff0c;主要记录的难点是如何 模拟人工滑速 具体原理和利用到的东西都有做注释&#xff0c;逻辑完整&#xff0c;小白还是可以尝试理解的 一、正常简单模拟滑动 目标网址&#xff1a;点击 import base64 import time im…

【全栈开发】RedwoodJS与BlitzJS:全栈JavaScript元框架的未来

Redwood和Blitz是两个即将出现的全栈元框架&#xff0c;它们提供了创建SPAs、服务器端渲染页面和静态生成内容的工具&#xff0c;并提供了生成端到端支架的CLI。我一直在等待一个有价值的Rails JavaScript替代品&#xff0c;谁知道什么时候。这篇文章是对两者的概述&#xff0c…

参数估计(三)区间估计

文章目录 区间估计的概念一个正态总体的情形 μ \mu μ 的区间估计 σ 2 \sigma^2 σ2 的区间估计 两个正态总体的情形 μ 1 − μ 2 \mu_1-\mu_2 μ1​−μ2​ 的区间估计 σ 1 2 / σ 2 2 \sigma_1^2/\sigma_2^2 σ12​/σ22​ 的区间估计 参考文献 区间估计的概念 对未知参…

opencv-利用DeepLabV3+模型进行图像分割去除输入图像的背景

分离图像中的人物和背景通常需要一些先进的图像分割技术。GrabCut是一种常见的方法&#xff0c;但是对于更复杂的场景&#xff0c;可能需要使用深度学习模型。以下是使用深度学习模型&#xff08;如人像分割模型&#xff09;的示例代码&#xff1a; #导入相关的库 import cv2 …

[C++]指针与结构体

标题 一.指针1.指针的定义和使用2.指针所占的内存空间3.空指针与野指针4.const修饰指针5.指针和数组6.指针和函数 二.结构体1.结构体的定义与使用2.结构体数组3.结构体指针4.结构体的嵌套使用5.结构体做函数参数6.结构体中const使用场景7.案例练习 一.指针 作用: 可以通过指针…

FPGA驱动CS4344 VHDL例程

CS4344是一款非常简单的I2S立体声24bit D/A芯片&#xff0c;采样率高达192KHz&#xff0c;相对于ADAU1761复杂的寄存器配置来说&#xff0c;CS4344非常友好&#xff0c;无需配置寄存器&#xff0c;只要按I2S时序输入数据&#xff0c;即可实现立体声输出&#xff0c;且10PIN TSS…

SpringBoot 拦截器高级篇

Springboot 拦截器 定义使用场景拦截器与过滤器的区别实现步骤全局拦截器的局限性全局拦截器VS局部拦截器局部拦截器自定义局部拦截器使用多个局部拦截器 定义 拦截器是Spring MVC框架中的一个重要组件&#xff0c;它是一种AOP&#xff08;面向切面编程&#xff09;的实现方式&…