JAVA 异步编程(线程安全)二

news2024/11/22 22:54:14

1、线程安全

        线程安全是指你的代码所在的进程中有多个线程同时运行,而这些线程可能会同时运行这段代码,如果每次运行的代码结果和单线程运行的结果是一样的,且其他变量的值和预期的也是一样的,那么就是线程安全的。

        一个类或者程序所提供的接口对于线程来说是原子操作或者多个线程之间的切换不会导致该接口的执行结果存在二义性,也就是说我们不用考虑同步的问题。
        线程安全问题都是由全局变量及静态变量引起的。若每个线程中对全局变量、静态变量只有读操作,而无写操作,一般来说,这个全局变量是线程安全的;若有多个线程同时执行
写操作,一般都需要考虑线程同步,否则就可能影响线程安全。

Java中Vector,HashTable,StringBuffer和java.util.concurrent下的集合类都是线程安全的

2、非线程安全

        是不提供代码数据访问保护,可能出现多个线程先后访问更改数据造成所得的数据是脏数据。*(脏数据是表示一个数据已经被修改,但是还没有保存或进一步的处理。
        例如你操作数据库修改某一字段内容,在你修改了但还没commit时,另一线程在读取这
数据,他读取的就是你修改前的数据,但事实上你已经修改了,这就是脏数据了。)*在多个线程同时访问同一个对象时会发生数据错误 不完整等情况时 那就是线程不安全。

这里展示一段代码,全局变量count就是线程不安全,这个count变量可能同时被三个线程进行写操作。

Java中HashMap,ArrayList,StringBuilder都是线程不安全的。

    private static Integer count = new Integer(100);

    public void noSafeMethod() {
        while (count > 0) {
            Util.mySleep(100);
            count--;
        }
        Util.printfLog("count=" + count + ";threadid=" + Thread.currentThread().getName());
    }
    /**
     * 线程不安全,三个线程同时修改,会导致count多减
     */
    private static void threadNoSafe() {
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        ThreadSafeTest threadSafeTest = new ThreadSafeTest();
        executorService.submit(threadSafeTest::noSafeMethod);
        executorService.submit(threadSafeTest::noSafeMethod);
        executorService.submit(threadSafeTest::noSafeMethod);
        executorService.shutdown();
    }

3、线程安全出现的根本原因

  • 存在两个或者两个以上的线程对象共享同一个资源;
  • 多线程操作共享资源代码有多个语句。
  • 存在竞争的线程不安全,不存在竞争的线程就是安全的

4、实现线程安全

        实现线程安全常用的方式有悲观锁(互斥同步锁),乐观锁(非阻塞同步锁例如基于CAS机制),无同步方案等方式

 4.1 悲观锁(互斥同步锁)。

     悲观锁也叫互斥同步锁,是一种阻塞机制,当前线程通过对当前资源的独占,进而实现线程安全。

        悲观锁总是假设最坏的情况,每次去拿数据的时候都认为别人会修改,所以每次在拿数据的时候都会上锁,这样别人想拿这个数据就会阻塞直到它拿到锁(共享资源每次只给一个线程使用,其它线程阻塞,用完后再把资源转让给其它线程)。传统的关系型数据库里边就用到了很多这种锁机制,比如行锁,表锁等,读锁,写锁等,都是在做操作之前先上锁。Java中synchronized和ReentrantLock等独占锁就是悲观锁思想的实现。

1. synchronized

    private static Integer count2 = 100;
    private static Object object = new Object();

    public void synchronizedMethod() {
        while (count2 > 0) {
            synchronized (object) {
                Util.mySleep(Double.valueOf(Math.random() * 10).intValue());
                if (count2 > 0) {
                    count2--;
                }
            }
        }
        Util.printfLog("synchronized:count2=" + count2 + ";threadname=" + Thread.currentThread().getName());
    }
    private static void threadSynchronized() {
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        ThreadSafeTest threadSafeTest = new ThreadSafeTest();
        executorService.submit(threadSafeTest::synchronizedMethod);
        executorService.submit(threadSafeTest::synchronizedMethod);
        executorService.submit(threadSafeTest::synchronizedMethod);
        executorService.shutdown();
    }

当某一个线程同对count资源的独占,进而实现 线程安全,不会像不安全代码一样出现负值。

        2. ReentrantLock

    private static Integer countLock = new Integer(100);
    ReentrantLock reentrantLock = new ReentrantLock();

    public void reentrantLockMethod() {
        while (countLock > 0) {
            reentrantLock.lock();
//            reentrantLock.tryLock(3, TimeUnit.SECONDS);
            Util.mySleep(100);
            //当解锁之后线程可能获取到的还是旧值(countLock已经被其他的线程加成0了),
            // 所以还需要再次判断,不然会被线程多减一次成为-1
            if (countLock > 0) {
                countLock--;
            }
            reentrantLock.unlock();
        }
        Util.printfLog("countLock=" + countLock + ";threadname=" + Thread.currentThread().getName());
    }

    private static void threadReentrantLock() {
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        ThreadSafeTest threadSafeTest = new ThreadSafeTest();
        executorService.submit(threadSafeTest::reentrantLockMethod);
        executorService.submit(threadSafeTest::reentrantLockMethod);
        executorService.submit(threadSafeTest::reentrantLockMethod);
        executorService.shutdown();
    }

3. 

3. Lock和synchronized对比 

1)synchronized是Java语言的关键字,因此是内置特性,Lock不是Java语言内置的,Lock是一个接口,通过实现类可以实现同步访问。

 2)synchronized是在JVM层面上实现的,不但可以通过一些监控工具监控synchronized的锁定,而且在代码执行时出现异常,JVM会自动释放锁定,但是使用Lock则不行,lock是通过代码实现的,要保证锁定一定会被释放,就必须将unLock()放到finally{}中

 3)在资源竞争不是很激烈的情况下,Synchronized的性能要优于ReetrantLock,但是在资源竞争很激烈的情况下,Synchronized的性能会下降几十倍,但是ReetrantLock的性能能维持常态。

 4)Lock 实现提供了比 synchronized 关键字 更广泛的锁操作,它能以更优雅的方式处理线程同步问题。

4.2 乐观锁(非阻塞同步锁)

        乐观锁是一种非阻塞锁。乐观锁总是假设最好的情况,每次去拿数据的时候都认为别人不会修改,所以不会上锁,但是在更新的时候会判断一下在此期间别人有没有去更新这个数据,可以使用版本号机制和CAS算法实现。乐观锁适用于多读的应用类型,这样可以提高吞吐量,像数据库提供的类似于write_condition机制,其实都是提供的乐观锁。Java中java.util.concurrent.atomic包下面的原子变量类就是使用了乐观锁的一种实现方式CAS实现的。  

        乐观锁一般会使用版本号机制(在更新或者删除时where增加时间字段等条件)或CAS算法实现。  

1.原子类(CAS)    

JUC中提供了几个Automic类以及每个类上的原子操作就是乐观锁机制。AtomicBoolean, AtomicInteger,AtomicLong,AtomicLongArray,AtomicReference等原子类的类,主要用于在高并发环境下的高效程序处理,来帮助我们简化同步处理.

    private static AtomicInteger atomicInteger = new AtomicInteger(100);

    public void atomicIntegerMethod() {
        while (atomicInteger.get() > 0) {
            Util.mySleep(100);
            int oldValue = atomicInteger.get();
            if (oldValue <= 0) {
                break;
            }
            int newValue = oldValue - 1;
            if (!atomicInteger.compareAndSet(oldValue, newValue)) {
//                System.out.println("threadName=" + Thread.currentThread().getName() + ";oldValue=" + oldValue + ";oldvaluelatest=" + atomicInteger.get());

            }
        }
        Util.printfLog("atomicInteger=" + atomicInteger.get() + ";threadname=" + Thread.currentThread().getName());
    }


    /**
     *
     */
    private static void threadAtomicInteger() {
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        ThreadSafeTest threadSafeTest = new ThreadSafeTest();
        executorService.submit(threadSafeTest::atomicIntegerMethod);
        executorService.submit(threadSafeTest::atomicIntegerMethod);
        executorService.submit(threadSafeTest::atomicIntegerMethod);
        executorService.shutdown();
    }

 乐观锁和悲观锁的使用场景

        从上面对两种锁的介绍,我们知道两种锁各有优缺点,不可认为一种好于另一种,像乐观锁适用于写比较少的情况下(多读场景),即冲突真的很少发生的时候,这样可以省去了锁的开销,加大了系统的整个吞吐量。但如果是多写的情况,一般会经常产生冲突,这就会导致上层应用会不断的进行retry,这样反倒是降低了性能,所以一般多写的场景下用悲观锁就比较合适。

4.4 无同步方案

1.可重入代码

        在执行的任何时刻都可以中断-重入执行而不会产生冲突。特点就是不会依赖堆上的共享资源

2.ThreadLocal/Volaitile

        线程本地的变量,每个线程获取一份共享变量的拷贝,单独进行处理。SpringBoot中的HttpServletRequest就是使用ThreadLocal实现了每次并发请求,HttpServletRequest是线程安全的。

3.线程本地存储

        如果一个共享资源一定要被多线程共享,可以尽量让一个线程完成所有的处理操作,比如生产者消费者模式中,一般会让一个消费者完成对队列上资源的消费。典型的应用是基于请求-应答模式的web服务器的设计。

5. 死锁的定义

5.1 死锁的定义

 多线程以及多进程改善了系统资源的利用率并提高了系统 的处理能力。然而,并发执行也带来了新的问题——死锁。所谓死锁是指多个线程因竞争资源而造成的一种僵局(互相等待),若无外力作用,这些进程都将无法向前推进。

     死锁是指两个或两个以上的线程在执行过程中,因争夺资源而造成的一种互相等待的现象,若无外力作用,它们都将无法推进下去。

5.2 死锁产生的原因

1、系统资源的竞争

2、进程推进顺序非法

3、死锁产生的必要条件

(1)互斥条件,(2)不剥夺条件,(3)请求和保持条件,(4)循环等待条件

5.3 如何避免死锁

  • 加锁顺序(线程按照一定的顺序加锁)
  • 加锁时限线程尝试获取锁的时候加上一定的时限,超过时限则放弃对该锁的请求,并释放自己占有的锁)
  • 死锁检测

参考:

Java深入学习11:Lock锁详解

面试必备之乐观锁与悲观锁

Java多线程:死锁

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

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

相关文章

Linux驱动开发-06蜂鸣器和多组GPIO控制

一、控制蜂鸣器 1.1 控制原理 我们可以看到SNVS_TAMPER1是这个端口在控制着蜂鸣器,同时这是一个PNP型的三极管,在端口输出为低电平时,蜂鸣器响,在高电平时,蜂鸣器不响 1.2 在Linux中端口号的控制 gpiochipX:当前SoC所包含的GPIO控制器,我们知道I.MX6UL/I.MX6ULL一共包…

整顿职场?安全体系建设

本文由 ChatMoney团队出品 00后整顿职场&#xff0c;职场到底怎么了&#xff1f;无压力、无忧虑的00后可以直接开整&#xff0c;那绝大部分打工人寒窗苦读、闯过高考&#xff0c;艰辛毕业&#xff0c;几轮面试杀入职场&#xff0c;结婚买房、上有老下有小&#xff0c;就活该再被…

怎么剪辑音频文件?4款适合新的音频剪辑软件

是谁还不会音频剪辑&#xff1f;无论是个人音乐爱好者&#xff0c;还是专业音频工作者&#xff0c;我们都希望能找到一款操作简便、功能强大且稳定可靠的音频剪辑工具。今天&#xff0c;我就要为大家带来四款热门音频剪辑软件的体验感分享。 一、福昕音频剪辑 福昕音频剪辑是…

JUnit 单元测试

JUnit 测试是程序员测试&#xff0c;就是白盒测试&#xff0c;可以让程序员知道被测试的软件如何 &#xff08;How&#xff09;完成功能和完成什么样&#xff08;What&#xff09;的功能。 下载junit-4.12和hamcrest-core-1.3依赖包 相关链接 junit-4.12&#xff1a;Central …

【JavaScript 算法】最长公共子序列:字符串问题的经典解法

&#x1f525; 个人主页&#xff1a;空白诗 文章目录 一、算法原理状态转移方程初始条件 二、算法实现注释说明&#xff1a; 三、应用场景四、总结 最长公共子序列&#xff08;Longest Common Subsequence&#xff0c;LCS&#xff09;是字符串处理中的经典问题。给定两个字符串…

Go语言之参数传递

文章收录在网站&#xff1a;http://hardyfish.top/ 文章收录在网站&#xff1a;http://hardyfish.top/ 文章收录在网站&#xff1a;http://hardyfish.top/ 文章收录在网站&#xff1a;http://hardyfish.top/ 修改参数 假设你定义了一个函数&#xff0c;并在函数里对参数进行…

string相关

int main() {// world替换成 xxxxxxxxxxxxxxxxxxxxxxstring s1("hello world hello bit");s1.replace(6, 5, "xxxxxxxxxxxxxxxxxxxxxx");cout << s1 << endl;s1.replace(6, 23, "yyyyy");cout << s1 << endl;// 所有空格…

C++ | Leetcode C++题解之第260题只出现一次的数字III

题目&#xff1a; 题解&#xff1a; class Solution { public:vector<int> singleNumber(vector<int>& nums) {int xorsum 0;for (int num: nums) {xorsum ^ num;}// 防止溢出int lsb (xorsum INT_MIN ? xorsum : xorsum & (-xorsum));int type1 0, …

类和对象:构造函数

构造函数是特殊的成员函数&#xff0c;需要注意的是&#xff0c;构造函数虽然名称叫构造&#xff0c;但是构造函数的主要任务并不是开空间创建对象(我们常使⽤的局部对象是栈帧创建时&#xff0c;空间就开好了)&#xff0c;⽽是对象实例化时初始化对象。构造函数的本质是要替代…

通过splunk web服务将服务器上文件下载到本地

1. 需求说明 工作中经常遇到需要将服务器上的文件下载到本地&#xff0c;但是由于各种网络环境限制&#xff0c;没办法使用winscp或者xftp工具&#xff0c;那么如何将服务器上的文件下载下来呢&#xff1f; 这里提供一种思路: 如果服务器上安装有web服务&#xff0c;可将待下…

MongoDB教程(十四):MongoDB查询分析

&#x1f49d;&#x1f49d;&#x1f49d;首先&#xff0c;欢迎各位来到我的博客&#xff0c;很高兴能够在这里和您见面&#xff01;希望您在这里不仅可以有所收获&#xff0c;同时也能感受到一份轻松欢乐的氛围&#xff0c;祝你生活愉快&#xff01; 文章目录 引言一、查询分…

防火墙之内容安全过滤技术篇

深度行为检测技术&#xff1a;是一种基于应用层的流量检测和控制技术 DPI:针对完整的数据包&#xff0c;进行内容的识别和检测 基于应用网关的检测技术 --- 有些应用控制和数据是分离的&#xff0c;比如一些视频流。一开始会通过TCP协议链接之后&#xff0c;协商一些参数&#…

扩容升级丨极海正式推出G32A1465系列汽车通用MCU,驱动智驾再进阶

继2023年推出G32A系列汽车通用平台首发产品G32A1445系列后&#xff0c;极海宣布正式推出G32A1465系列全新汽车通用MCU&#xff0c;以满足日益增长的智能驾驶应用需求。作为升级迭代产品&#xff0c;G32A1465专为应用范围不断扩大的高运算要求而设计&#xff0c;集成丰富的通信接…

服务器证书基于 OpenSSL一键颁发脚本

文章目录 一、场景说明二、脚本职责三、参数说明四、操作示例五、注意事项 一、场景说明 本自动化脚本旨在为提高研发、测试、运维快速部署应用环境而编写。 脚本遵循拿来即用的原则快速完成 CentOS 系统各应用环境部署工作。 统一研发、测试、生产环境的部署模式、部署结构、…

【Vue】深入了解 Axios 在 Vue 中的使用:从基本操作到高级用法的全面指南

文章目录 一、Axios 简介与安装1. 什么是 Axios&#xff1f;2. 安装 Axios 二、在 Vue 组件中使用 Axios1. 发送 GET 请求2. 发送 POST 请求 三、Axios 拦截器1. 请求拦截器2. 响应拦截器 四、错误处理五、与 Vuex 结合使用1. 在 Vuex 中定义 actions2. 在组件中调用 Vuex acti…

Elasticsearch:Retrievers 介绍 - Python Jupyter notebook

在今天的文章里&#xff0c;我是继上一篇文章 “Elasticsearch&#xff1a;介绍 retrievers - 搜索一切事物” 来使用一个可以在本地设置的 Elasticsearch 集群来展示 Retrievers 的使用。在本篇文章中&#xff0c;你将学到如下的内容&#xff1a; 从 Kaggle 下载 IMDB 数据集…

[米联客-安路飞龙DR1-FPSOC] FPGA基础篇连载-21 VTC视频时序控制器设计

软件版本&#xff1a;Anlogic -TD5.9.1-DR1_ES1.1 操作系统&#xff1a;WIN10 64bit 硬件平台&#xff1a;适用安路(Anlogic)FPGA 实验平台&#xff1a;米联客-MLK-L1-CZ06-DR1M90G开发板 板卡获取平台&#xff1a;https://milianke.tmall.com/ 登录“米联客”FPGA社区 ht…

SpringDoc2问题汇总

在项目中尝试使用SpringDoc进行文档生成&#xff0c;在使用过程中遇到一系列的问题加以记录. 1.引入依赖 只是单纯的使用SpringDoc的话不需要引入一些乱七八糟的依赖&#xff0c;如今各种增强和拓展依赖层出不穷&#xff0c;但是随着这些依赖的出现带来的不仅是增强&#xff0…

【BUG】已解决:ModuleNotFoundError: No module named ‘PIL‘

已解决&#xff1a;ModuleNotFoundError: No module named ‘PIL‘ 目录 已解决&#xff1a;ModuleNotFoundError: No module named ‘PIL‘ 【常见模块错误】 错误原因&#xff1a; 解决办法&#xff1a; 欢迎来到英杰社区https://bbs.csdn.net/topics/617804998 欢迎来到我…

【性能优化】在大批量数据下使用 HTML+CSS实现走马灯,防止页面卡顿

切换效果 页面结构变化 1.需求背景 项目首页存有一个小的轮播模块,保密原因大概只能这么展示,左侧图片右侧文字,后端一次性返回几百条数据(开发环境下,生产环境只会更多).无法使用分页解决,前端需要懒加载防止页面卡顿 写个小demo演示,如下 2.解决思路 获取到数据后,取第一…