Java中如何进行加锁??

news2024/11/27 7:36:57

笔者在上篇文章介绍了线程安全的问题,接下来本篇文章就是来讲解如何避免线程安全问题~~
前言:创建两个线程,每个线程都实现对同一个变量count各自自增5W次,我们来看一下代码:

class Counter{
    private int count=0;

    public void add(){
        count++;
    }

    public int get(){
        return count;
    }
}
public class Main2 {
    public static void main(String[] args) throws InterruptedException{
        Counter counter=new Counter();

        //搞两个线程,两个线程分别对这个count自增5W次
        //线程1
        Thread t1=new Thread(()->{
            for (int i = 0; i < 50000; i++) {
                counter.add();
            }
        });

        //线程2
        Thread t2=new Thread(()->{
            for (int i = 0; i < 50000; i++) {
                counter.add();
            }
        });

        //启动线程
        t1.start();
        t2.start();

        //等待两个线程执行结束,然后看一下结果
        t1.join();
        t2.join();

        System.out.println(counter.get());
        //预期结果是10W,但是,实际结果像是一个随机值,每次执行的结果都不一样
    }
}

上述代码的运行结果是不确定的,是一个随即值,多次刷新重新运行,结果大概率是不一样的~,预期效果个代码的运行结果不一样,这就是Bug——》线程安全问题!
通过加锁来有效避免线程安全问题:
Synchronized是Java中的关键字,可以使用这个关键字来实现加锁的效果~

    public void add(){
       // count++;
        synchronized (this){
            //这里的this可以写任意一个Object对象(基本数据类型不可)
            //此处写了this就相当于Counter counter=new Counter();中的counter
            count++;
        }
    }

那么,我们来看一下此时代码的运行结果~
在这里插入图片描述符合我们预期的一个效果~
锁有两个核心的操作,加锁和解锁;
此处使用代码块的方式来表示:进入synchronized修饰的代码块的时候,就会触发加锁,出了synchronized代码块就会触发解锁,{ }就相当于WC~~
在上述代码中:synchronized(this)——》this是指:锁对象(在针对哪个对象?)!

如果两个线程针对同一个对象加锁,此时就会出现“锁竞争”(一个线程先拿到锁,另一个线程阻塞等待)!
如果两个线程针对不同的对象加锁,此时不好存在锁竞争,各种获取各自锁即可!
加锁本质上是把并发的变成了串行的~

join()和加锁不一样:
join()是让两个线程完整的进行串行~
加锁是让两个线程的某小部分串行了,大部分都是并发的!!

在这里插入图片描述加锁:在保证线程安全的前提下,同时还能够让代码跑的更快一些,更好的利用CPU,无论如何,加锁都可能导致阻塞,代码阻塞对应程序的效率肯定还是会有影响的,此处虽然加锁了,比不加锁要慢点,肯定还是比串行要更快,同时比不加锁算得更准!!
在这里插入图片描述如果直接给方法使用synchronized修饰,此时就相当于this为加锁对象!!
如果synchronized修饰静态方法static(),此时就算不给this加锁了,而是给类对象加锁!!
在这里插入图片描述更常见的还是自己手动指定一个锁对象:

    //自己手动指定锁对象
    private Object locker=new Object();
    public void add(){
        synchronized (locker){
            //这里的locker可以写任意一个Object对象(基本数据类型不可)
            count++;
        }
    }

要牢记:如果多个线程尝试对同一对象加锁,此时就会产生锁竞争!!针对不同的锁对象加锁,就不会有锁竞争~

另一个线程不安全的场景:由于内存可见性,所引起的线程不安全~
先写一个带有Bug的代码:

import java.util.Scanner;

public class Main3 {
    public static int flag=0;

    public static void main(String[] args) {
        Thread t1=new Thread(()->{
            while (flag==0){
                //空着,啥都没有
            }
            System.out.println("循环结束,t1结束");
        });
        
        Thread t2=new Thread(()->{
            Scanner scanner=new Scanner(System.in);
            System.out.println("请输入一个整数: ");
            flag=scanner.nextInt();
        });

        t1.start();
        t2.start();
    }
}

对该段代码的预期效果:t1通过flag=0作为条件,进行循环,初始情况下,将进入循环,t2通过控制台输入一个整数,一旦用户输入非0的值,此时t1的循环就会立即结束,从而t1线程退出!!
但是,实际的效果:输入非0的值之后,t1线程并没有退出,循环没有结束!通过jconsole可以看到t1线程仍然在执行,处在RUNNABLE状态。
实际效果 !=预期效果——》这就是Bug
为啥有这个问题??这就是内存可见性的锅!!
所谓的内存可见性,就是多线程环境下,,编辑器对于代码优化产生了误判,从而引起了Bug,进一步导致了咱们的Bug,咱们的处理方式:就是让编辑器针对这个场景暂停优化!!使用Volatile关键字,被volatile修饰的变量,此时编辑器就会紧张上述优化,从而能够确保每次都是从内存中重新读取数据~
即:针对上述代码的更改:

volatile public static int flag=0;

加上volatile关键字之后,此时编辑器就能够保证每次都是重新从内存读取flag变量的值,此时t2修饰flag,t1就可以立即感知到了,因此t1就可以正确退出了~

volatile不保证原子性(注意)
volatile适用的场景是一个线程读,一个线程写的情况
synchronized则是多个线程写

volatile的这个效果称为:“保证内存可见性”
synchronized不确定能不能保证内存可见性

volatile还有一个效果:禁止指令重排序!指令重排序也是编辑器优化的策略(调整了代码执行的顺序,,让程序更高效,前台也是保证整体逻辑不变)

关于volatile和内存可见性的补充~
网上有效资料:线程修改一个变量,会把这个变量先从主内存读取到工作内存,然后修改工作内存的值,再写回到主内存中~
内存可见性:t1频繁读取主内存,效率比较低,就被优化成直接读取自己的工作内存,t1修改了主内存的结果,由于t1没有读取主内存导致修改不能被识别到!!
工作内存《——》CPU寄存器
主内存《——》内存

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

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

相关文章

玩转宝塔,持续更新

用了下宝塔是真的比较爽&#xff0c;这里介绍下安装 1.linux安装宝塔 linux服务器直接安装输入就好 yum install -y wget && wget -O install.sh https://download.bt.cn/install/install_6.0.sh && sh install.sh ed8484bec2.部署项目 2.1安装套件 这里直…

datax工具介绍及简单使用

介绍 Datax是一个异构数据源离线同步工具&#xff0c;致力于实现包括关系数据库、HDFS、Hive、ODPS、Hbase等各种异构数据源之间稳定高效的数据同步功能 设计理念 为了解决异构数据源同步问题&#xff0c;DataX将复杂的网状的同步链路变成了星型数据链路&#xff0c;DataX作为…

Java转网络安全渗透测试,挖漏洞真香啊

最近&#xff0c;一个做运维的朋友在学渗透测试。他说&#xff0c;他公司请别人做渗透测试的费用是 2w/人天&#xff0c;一共2周。2周 10w 的收入&#xff0c;好香~ 于是&#xff0c;我也对渗透测试产生了兴趣。开始了探索之路~ 什么是渗透测试 渗透测试这名字听起来有一种…

Java实现自动玩王铲铲的致富之路小程序游戏

文章目录 前言1.调用adb命令截屏并读取到电脑2.打开游戏&#xff0c;提前截几个图&#xff0c;准备好相应的按钮位置颜色3.根据图片路径和x,y坐标&#xff0c;读取图片相应位置的颜色值4.根据颜色值判断如何进行触摸操作5.程序效果分析5.存在的问题6.改进思路7.改进版本&#x…

vue3中通过ref获取子组件实例,取值为undefined

也就是Vue3如何通过 ref 获取子组件实例(子组件中的DOM结构、数据、及方法)&#xff0c;今天写index.vue(父组件&#xff09;时想获取子组件的数据和方法&#xff0c;通过给子组件绑定ref&#xff0c;打印子组件的数据为undefined&#xff1b;百度搜索常用方法为&#xff1a; …

小白参加红队,需要做好哪些准备?

在本文中&#xff0c;我们将为读者介绍要想加入红队&#xff0c;需要掌握哪些方面的技能。 CSDN大礼包&#xff1a;《黑客&网络安全入门&进阶学习资源包》免费分享 护网的定义是以国家组织组织事业单位、国企单位、名企单位等开展攻防两方的网络安全演习。进攻方一个…

【多线程】Thread 类 详解

Thread 类 详解 一. 创建线程1. 继承 Thread 类2. 实现 Runnable 接口3. 其他变形4. 多线程的优势-增加运行速度 二. Thread 类1. 构造方法2. 常见属性3. 启动线程-start()4. 中断线程-interrupt()5. 线程等待-join()6. 线程休眠-sleep()7. 获取当前线程引用 三. 线程的状态1. …

redis主从复制、哨兵、集群模式

redis群集有三种模式 redis群集有三种模式&#xff0c;分别是主从同步/复制、哨兵模式、Cluster&#xff0c;下面会讲解一下三种模式的工作方式&#xff0c;以及如何搭建cluster群集 ●主从复制&#xff1a;主从复制是高可用Redis的基础&#xff0c;哨兵和集群都是在主从复制…

Shell命令管理进程

Shell命令管理进程 列出进程 ps命令 top命令 管理后台进程 启动后台进程 查看后台进程 jobs和ps的区别 停止进程 Linux除了是一种多用户操作系统之外&#xff0c;还是一种多任务系统。多任务意味着可以同时运行多个程序。Linux 提供了相关的工具来列出运行中的进程,监视…

24、DAPlink仿真器-STM32F103C8T6

参考文章&#xff1a; A、https://oshwhub.com/nice0513/daplink-fang-zhen-qi B、https://oshwhub.com/Southerly/daplink-fang-zhen-qi-swd C、https://oshwhub.com/jixin002/stm32f103c8t6_cmsis-dap 串口烧录Hex文件 问题&#xff1a;不支持U盘拖拽&#xff0c;没有识别出U…

Java使用本地浏览器打开网页工具类分享

本文主要分享一个封装工具类&#xff0c;该工具类已实现查找本地可运行的浏览器打开网页。 package com;import java.lang.reflect.Method;/*** browse util** author Roc-xb*/ public class BrowseUtil {public static final String[] BROWSERS {"firefox", "…

UDP协议和报文格式,校验和,CRC的含义

&#x1f496;&#x1f496;&#x1f496;每日一看&#xff0c;学习动力 一、UDP协议及其报文格式 UDP&#xff1a;特点&#xff1a;无连接&#xff0c;不可靠传输 报头里面有啥呢&#xff1f; 那么首先我要先提问一下&#xff1f;2个字节&#xff0c;可以表示的数据范围有多大…

【Sentinel Go】新手指南、流量控制、熔断降级和并发隔离控制

随着微服务的流行&#xff0c;服务和服务之间的稳定性变得越来越重要。Sentinel 是面向分布式、多语言异构化服务架构的流量治理组件&#xff0c;主要以流量为切入点&#xff0c;从流量路由、流量控制、流量整形、熔断降级、系统自适应过载保护、热点流量防护等多个维度来帮助开…

C语言入门Day_17 循环的控制

目录 前言 1.break 2.continue 3.易错点 4.思维导图 前言 我们知道当循环判断的边界条件不成立以后&#xff0c;循环就结束了。除此以外&#xff0c;我们如果想要提前结束循环&#xff0c;或者在循环中跳过某一次循环代码的执行&#xff0c;应该怎么做呢&#xff1f; 假如…

数据治理-数据架构-企业数据架构

是什么 数据架构定义了对组织非常重要元素的标准术语和设计。企业数据架构的设计中包括业务数据描述&#xff0c;如数据的收集、存储、整合、移动和分布。 当数据在组织中通过源或者接口流动时&#xff0c;需要安全、集成、存储、记录、分类、共享的报表和分析&#xff0c;最终…

3D目标检测数据集 KITTI(标签格式解析、点云转图像、点云转BEV)

本文介绍在3D目标检测中&#xff0c;理解和使用KITTI 数据集&#xff0c;包括KITTI 的基本情况、下载数据集、标签格式解析、点云转图像、点云转BEV。 目录 1、KITTI数据集中3D框可视化的效果 2、先看个视频&#xff0c;了解KITTI 的基本情况 3、来到KITTI官网&#xff0c;下…

C++ 11:多线程相关问题

目录 一. 线程类thread 1.1 thread的一些接口函数 2.2 通过thread创建多线程 二. this_thread 三. 互斥锁与原子操作 3.1 多线程中的加锁与解锁 3.1.1 mutex类 3.1.2 lock_guard 类 3.3 原子性操作 四. 条件变量 4.1 线程互斥的缺陷 4.2 condition_variable 实现线程…

图片mask任务和自监督损失函数MAE、Beit、MarkFeature、DINO、DINOv2

MAE (Masked Autoencoders Are Scalable Vision Learners) 来自Masked Autoencoders Are Scalable Vision Learners&#xff0c;Our loss function computes the mean squared error (MSE) between the reconstructed and original images in the pixel space. 几个关键点&…

无涯教程-JavaScript - IMSUB函数

描述 IMSUB函数以x yi或x yj文本格式返回两个复数的差。减去复数时,实数和虚数系数分别相减,即从复数a bi中减去复数c di的方程为- (a bi)-(c in)(a-c)(b-d)我 语法 IMSUB (inumber1, inumber2)争论 Argument描述Required/OptionalInumber1The complex number from …

【C++】可变参数模板

2023年9月9日&#xff0c;周六下午 这个还是挺难学的&#xff0c;我学了好几天... 在这里我会举大量的示例程序&#xff0c;这样可以有一个更好的理解&#xff0c; 不定期更新。 目录 推荐文章&#xff1a; 示例程序一&#xff1a;拼接字符串 示例程序二&#xff1a;求整…