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

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了),// 所以还需要再次判断,不然会被线程多减一次成为-1if (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.mzph.cn/bicheng/48511.shtml

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

相关文章

https和http有哪些区别?

在今天的互联网世界中&#xff0c;我们经常听到关于HTTPS和HTTP的术语。它们都是超文本传输协议&#xff08;HTTP&#xff09;的变种&#xff0c;但它们之间存在着重要的区别。本篇博客将深入探讨HTTPS与HTTP之间的差异以及为什么HTTPS在现代网络中变得如此重要。 目录 1. HT…

多线程初阶(二)- 线程安全问题

目录 1.观察count 原因总结 2.解决方案-synchronized关键字 &#xff08;1&#xff09;synchronized的特性 &#xff08;2&#xff09;如何正确使用 语法格式 3.死锁 &#xff08;1&#xff09;造成死锁的情况 &#xff08;2&#xff09;死锁的四个必要条件 4.Java标准…

[C/C++入门][for]22、输出奇偶数之和

复习一下我们前面如何判断奇数 判断一个整数是奇数还是偶数&#xff0c;最常用的方法是利用模运算&#xff08;%&#xff09;。模运算符返回除法的余数。对于任何整数n&#xff0c;当你用n % 2&#xff08;n模2&#xff09;来计算时&#xff0c;如果结果是0&#xff0c;那么n就…

异常:android.os.NetworkOnMainThreadException 原因分析

1.错误异常&#xff1a;android.os.NetworkOnMainThreadException 2.原因分析&#xff1a;出现这个错误一般是数据请求在主线程中进行的&#xff0c;所以只要把耗时操作放到子线程中&#xff0c;更新UI在主线中操作。 3.解决方案demo&#xff1a; 创建一个独立的线程&#xf…

若依二次开发

口味改造 原&#xff1a; 改造&#xff1a; 1./** 定义口味名称和口味列表的静态数据 */ 2.改变页面样式 3.定义储存当前选中的口味列表数组&#xff0c;定义改变口味名称时更新当前的口味列表 4.改变页面样式 6.格式转换 7.定义口味列表获取焦点时更新当前选中的口味列表

【DGL系列】简单理解graph.update_all和spmm的区别

转载请注明出处&#xff1a;小锋学长生活大爆炸[xfxuezhagn.cn] 如果本文帮助到了你&#xff0c;欢迎[点赞、收藏、关注]哦~ 目录 背景介绍 源码分析 小结一下 背景介绍 我们在看GNN相关的论文时候&#xff0c;都会说到邻接矩阵与特征矩阵之间是用到了spmm&#xff0c;在很久…

深入理解Linux网络(二):UDP接收内核探究

深入理解Linux网络&#xff08;二&#xff09;&#xff1a;UDP接收内核探究 一、UDP 协议处理二、recvfrom 系统调⽤实现 一、UDP 协议处理 udp 协议的处理函数是 udp_rcv。 //file: net/ipv4/udp.c int udp_rcv(struct sk_buff *skb) {return __udp4_lib_rcv(skb, &udp_…

c++ 元组实验

在C中&#xff0c;元组&#xff08;tuple&#xff09;是一种可以存储不同类型元素的数据结构。C11引入了<tuple>库&#xff0c;使得在C中使用元组变得更加容易。下面是一个简单的C元组实验&#xff0c;展示了如何创建元组、访问元组元素以及使用std::get和std::tie等函数…

【Vue3】选项式 API

【Vue3】选项式 API 背景简介开发环境开发步骤及源码总结 背景 随着年龄的增长&#xff0c;很多曾经烂熟于心的技术原理已被岁月摩擦得愈发模糊起来&#xff0c;技术出身的人总是很难放下一些执念&#xff0c;遂将这些知识整理成文&#xff0c;以纪念曾经努力学习奋斗的日子。…

thinkphp6连接kingbase数据库

在/vendor/topthink/think-orm/src/db/connector中将Pgsql.php和pgsql.sql文件复制后改名为Kingbase.php和Kingbase.sql Kingbase.php <?php // ---------------------------------------------------------------------- // | ThinkPHP [ WE CAN DO IT JUST THINK ] // …

MySQL中EXPLAIN关键字详解

昨天领导突然问到&#xff0c;MySQL中explain获取到的type字段中index和ref的区别是什么。 这两种状态都是在使用索引后产生的&#xff0c;但具体区别却了解不多&#xff0c;只知道ref相比于index效率更高。 因此&#xff0c;本文较为详细地记录了MySQL性能中返回字段的含义、状…

使用Excel表格还是JSON数据来将数据存入Neo4的选择要素

在选择使用Excel表格还是JSON数据来将数据存入Neo4j时&#xff0c;需要考虑多个因素&#xff0c;包括数据的复杂性、规模、已有的数据处理工具以及你的个人或团队的熟悉度。以下是对两者的一些比较&#xff0c;帮助你做出选择&#xff1a; Excel表格 优点&#xff1a; 直观性…

Oracle(13)什么是外键(Foreign Key)?

外键&#xff08;Foreign Key&#xff09;是一个数据库表中的列或一组列&#xff0c;它们用于建立和强化两个表之间的链接和关系。外键指向另一个表的主键&#xff0c;用于确保数据的一致性和完整性。通过外键&#xff0c;可以保证一个表中的值必须来源于另一个表中的主键值。 …

【web】-反序列化-to_string

<?php highlight_file(__FILE__); class A{public $s;public function __destruct(){echo "hello".$this->s;}} class B{public $cmd;public function __toString(){system($this->cmd);return 1;} } unserialize($_GET[code]); __toString()当对象被当着…

探索特征的隐秘关系:在Scikit-Learn中进行特征交互性分析

探索特征的隐秘关系&#xff1a;在Scikit-Learn中进行特征交互性分析 在机器学习模型中&#xff0c;特征交互性分析是一种揭示特征之间相互作用对模型输出影响的技术。Scikit-Learn&#xff08;简称sklearn&#xff09;&#xff0c;作为Python中广泛使用的机器学习库&#xff…

【Linux服务器Java环境搭建】013 springboot + vue 前后端分离项目详细介绍(理论)

系列文章目录 【Linux服务器Java环境搭建】_一起来学吧的博客-CSDN博客 前言 在之前系列文章Linux服务器Java环境搭建 中&#xff0c;已经在CentOS中将所有环境及所需组件都安装完成了&#xff0c;比如git、jdk、nodejs、maven、mysql、clickhouse、redis、Nginx、rabbitMQ等…

《梦醒蝶飞:释放Excel函数与公式的力量》17.1使用命名范围和工作表函数

第17章&#xff1a;使用命名范围和工作表函数 17.1 命名范围的优势 在Excel中&#xff0c;使用命名范围是一个强大且灵活的功能&#xff0c;它可以极大地提高工作效率和公式的可读性。命名范围不仅使公式更容易理解&#xff0c;还减少了错误的可能性。以下将详细介绍命名范围的…

C++ STL equal_range 用法

一&#xff1a;功能 用于查找元素&#xff0c;它返回了 lower_bound, upper_bound 这两个函数查找结果值。 1. lower_bound 是返回第一个大于等于查找元素的位置。 2. upper_bound 是返回第一个大于查找元素的位置 二&#xff1a;用法 #include <vector> #include &l…

C++案例三:猜数字游戏

文章目录 介绍代码说明设置随机种子生成随机数猜测循环完整代码运行效果介绍 猜数字游戏是一个经典的编程练习,通过这个案例可以学习到基本的输入输出、随机数生成、条件判断和循环结构。 代码说明 设置随机种子 std::srand(static_cast<unsigned int>(std::time(nu…

自然语言大模型介绍

1 简介 最近一直被大语言模型刷屏。本文是周末技术分享会的提纲&#xff0c;总结了一些自然语言模型相关的重要技术&#xff0c;以及各个主流公司的研究方向和进展&#xff0c;和大家共同学习。 2 Transformer 目前的大模型基本都是Transformer及其变种。本部分将介绍Transf…