java线程安全问题原因及解决办法

1.为什么会出现线程安全问题

计算机系统资源分配的单位为进程,同一个进程中允许多个线程并发执行,并且多个线程会共享进程范围内的资源:例如内存地址。当多个线程并发访问同一个内存地址并且内存地址保存的值是可变的时候可能会发生线程安全问题,因此需要内存数据共享机制来保证线程安全问题。

对应到java服务来说,在虚拟中的共享内存地址是java的堆内存,比如以下程序中线程安全问题:

public class ThreadUnsafeDemo {private static final ExecutorService EXECUTOR_SERVICE;static {EXECUTOR_SERVICE = new ThreadPoolExecutor(100, 100, 1000 * 10,TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(100), new ThreadFactory() {private AtomicLong atomicLong = new AtomicLong(1);@Overridepublic Thread newThread(Runnable r) {return new Thread(r, "Thread-Safe-Thread-" + atomicLong.getAndIncrement());}});}public static void main(String[] args) throws Exception {Map<String, Integer> params = new HashMap<>();List<Future> futureList = new ArrayList<>(100);for (int i = 0; i < 100; i++) {futureList.add(EXECUTOR_SERVICE.submit(new CacheOpTask(params)));}for (Future future : futureList) {System.out.println("Future result:" + future.get());}System.out.println(params);}private static class CacheOpTask implements Callable<Integer> {private Map<String, Integer> params;CacheOpTask(Map<String, Integer> params) {this.params = params;}@Overridepublic Integer call() {for (int i = 0; i < 100; i++) {int count = params.getOrDefault("count", 0);params.put("count", ++count);}return params.get("count");}}
}

创建100个task,每个task对map中的元素累加100此,程序执行结果为:

{count=9846}

而预期的正确结果为:

{count=10000}

至于出现这种问题的原因,下面会具体分析。

判断是否有线程安全性的一个原则是:

是否有多线程访问可变的共享变量

2.多线程的优势

发挥多处理器的强大能力,提高效率和程序吞吐量

3.并发带来的风险

使用并发程序带来的主要风险有以下三种:

3.1.安全性问题:

竞态条件:由于不恰当的执行时序而出现不正确的结果

对于1中的线程安全的例子就是由于竞态条件导致的最终结果与预期结果不一致。关键代码块如下:

int count = params.getOrDefault("count", 0);
params.put("count", ++count);

当多个线程同时取的count的值的时候,每个线程计算之后,在写入到count,这时候会出现多个线程值被覆盖的情况,最终导致结果不正确。
如下图所示:929184-20180715150700914-1983734855.png

3.2解决此类问题的几种方法

1.使用同步机制限制变量的访问:锁
比如:

synchronized (LOCK) {int count = params.getOrDefault("count", 0);params.put("count", ++count);
}

2.将变量设置为不可变

即将共享变量设置为final

3.不在线程之间共享此变量ThreadLocal

编程的原则:首先编写正确的代码,然后在实现性能的提升
无状态的类一定是线程安全的

3.3 内置锁

内置锁:同步代码块( synchronized (this) {})

进入代码块前需要获取锁,会有性能问题。内置锁是可重入锁,之所以每个对象都有一个内置锁,是为了避免显示的创建锁对象

常见的加锁约定:将所有的可变状态都封装在对象内部,并使用内置锁对所有访问可变状态的代码进行同步。例如:Vector等

同步的另一个功能:内存可见性,类似于volatile

非volatile的64位变量double、long:
JVM允许对64位的操作分解为两次32位的两次操作,可变64位变量必须用volatile或者锁来保护

加锁的含义不仅在于互斥行为,还包括内存可见性,为了所有线程都可以看到共享变量的最新值,所有线程应该使用同一个锁

原则:
==除非需要跟高的可见性,否则应该将所有的域都声明为私有的,除非需要某个域是可变的,否则应该讲所有的域生命为final的==

2.活跃性问题

线程活跃性问题主要是由于加锁不正确导致的线程一直处于等待获取锁的状态,比如以下程序:

public class DeadLock {private static final Object[] LOCK_ARRAY;static {LOCK_ARRAY = new Object[2];LOCK_ARRAY[0] = new Object();LOCK_ARRAY[1] = new Object();}public static void main(String[] args) throws Exception {TaskOne taskOne = new TaskOne();taskOne.start();TaskTwo taskTwo = new TaskTwo();taskTwo.start();System.out.println("finished");}private static class TaskOne extends Thread {@Overridepublic void run(){synchronized (LOCK_ARRAY[0]) {try {Thread.sleep(3000);} catch (Exception e) {}System.out.println("Get LOCK-0");synchronized (LOCK_ARRAY[1]) {System.out.println("Get LOCK-1");}}}}private static class TaskTwo extends Thread {@Overridepublic void run() {synchronized (LOCK_ARRAY[1]) {try {Thread.sleep(1000 * 3);} catch (Exception e) {}System.out.println("Get LOCK-1");synchronized (LOCK_ARRAY[0]) {System.out.println("Get LOCK-0");}}}}
}

在两个线程持有一个锁,并在在锁没有释放之前,互相等待对方持有的锁,这时候会造成两个线程会一直等待,从而产生死锁。在我们使用锁的时候应该考虑持有锁的时长,特别是在网络I/O的时候。

在使用锁的时候要尽量避免以上情况,从而避免产生死锁

3.性能问题

在使用多线程执行程序的时候,在线程间的切换以及线程的调度也会消耗CPU的性能。

转载于:https://www.cnblogs.com/vitasyuan/p/9313625.html

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

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

相关文章

html语言怎么添加图片,我想问你一下,你是怎么在html中插入本地图片?非常感谢...

满意答案小蜜蜂手工2013.10.03采纳率&#xff1a;43% 等级&#xff1a;12已帮助&#xff1a;7929人img{float:right}在下面的段落中&#xff0c;我们添加了一个样式为 float:right 的图像。结果是这个图像会浮动到段落的右侧。This is some text. This is some text. This i…

数组实现矩阵逐层向内层加1

package java1701;public class javaMain { public static void main(String[] args) { // 逐层加 // 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 // 1 2 2 2 2 1 1 2 2 2 1 1 2 2 1 1 2 1 // 1 2 3 3 2 1 1 2 3 2 1 1 2 2 1 1 1 1 // 1 2 3 …

EntityFrameworkCore上下文如何实现继承?

【导读】如果我们存在基础设施服务和其他服务&#xff0c;我们会定义属于基础设施服务的上下文以及其他服务的上下文&#xff0c; 而且会独立部署&#xff0c;此时其他服务需要使用基础服务&#xff0c;我们都会暴露基础服务接口给到其他服务调用&#xff0c;这也是常规操作若在…

Unity 游戏框架搭建 (九) 减少加班利器-QConsole

为毛要实现这个工具? 在我小时候,每当游戏在真机运行时,我们看到的日志是这样的。 没高亮啊,还有乱七八糟的堆栈信息,好干扰日志查看,好影响心情。 还有就是必须始终连着usb线啊&#xff0c;我想要想躺着测试。。。 以上种种原因,QConsole诞生了。 如何使用? 使用方式和QLog…

android蓝牙多次后,android – 如何防止BluetoothGattCallback一次多次执行

我的服务有一个BluetoothGattCallback实例public class MyService extends Service {private BluetoothGattCallback callback;Overridepublic void onCreate() {super.onCreate();callback new BluetoothGattCallback() {Overridepublic synchronized void onConnectionState…

美观又实用,10 款强大的开源 Javascript 图表库

2019独角兽企业重金招聘Python工程师标准>>> 随着发展&#xff0c;现代 Web 设计在改善体验和功能的同时&#xff0c;对于美观的追求也越来越高&#xff0c;可视化、交互式、动态等元素和效果似乎已成为标配。 以下是为开发者推荐的 10 款开源 Javascript 图表库&am…

EF CORE 7 RC1 发布

原文链接&#xff1a;https://devblogs.microsoft.com/dotnet/announcing-ef7-rc1/[1]原文作者&#xff1a;Jeremy Likness翻译&#xff1a;沙漠尽头的狼(谷歌翻译加持)Entity Framework Core 7 (EF7) Release Candidate 1 已发布&#xff01;该团队专注于解决缺陷、小幅改进以…

0 重新学习Ubuntu -- 这一段没怎么学习

在完成了前面的几个学习后&#xff0c;再没有进行系统的学习。 虽然在真机上安装系统&#xff0c;每天都打开&#xff0c;完成以下的工作&#xff1a; 升级软件用来查看相关的网站在Ubuntu上&#xff0c;现在可以完成办公、上网、娱乐。 但专业的学习&#xff0c;例如编程方面进…

自定义地图怎么做成html,自定义html为谷歌地图制作标记

好吧&#xff0c;似乎Custom Overlays会做我想要的。这是ping层&#xff1a;function PingLayer(bounds, map) {this.bounds bounds;this.setMap(map);}PingLayer.prototype new google.maps.OverlayView();PingLayer.prototype.onAdd function() {var div document.create…

HDU5248:序列变换(二分)

序列变换 Time Limit: 4000/2000 MS (Java/Others) Memory Limit: 32768/32768 K (Java/Others) Total Submission(s): 1348 Accepted Submission(s): 593Problem Description给定序列A{A1,A2,...,An}, 要求改变序列A中的某些元素&#xff0c;形成一个严格单调的序列B&am…

微服务太分散?使用Fundebug集中式bug监控

摘要&#xff1a; 微服务日志分散&#xff0c;可以使用Fundebug的异常监控将它们集中起来。 当一个项目复杂到一定程度&#xff0c;功能越来越多&#xff0c;随之对应的模块也越来越多。 如果都放在一个大的项目下面&#xff0c;共同开发&#xff0c;整合发布&#xff0c;那么会…

html404页面怎么添加,网站要如何设置自定义404页面?

之前我们讲述过网站设置404页面对于优化或是用户体验的重要意义&#xff0c;大家可移步到《网站为什么要设置404页面》查看&#xff0c;今天我们讲解的是网站要如何设置自己的404页面。现在大多数空间商都有了404设置的功能&#xff0c;我们可将404页面上传至空间里面&#xff…

设计模式之——工厂方法模式

1、工厂方法模式&#xff08;Factory Method&#xff09;工厂方法模式分为三种&#xff1a;11、普通工厂模式&#xff0c;就是建立一个工厂类&#xff0c;对实现了同一接口的一些类进行实例的创建。首先看下关系图&#xff1a;举例如下&#xff1a;&#xff08;我们举一个发送邮…

记一次性能故障排查

最近一次公司服务出了一些性能的问题&#xff0c;主要是内存不释放。领到任务后就开始展开工作。项目是用.net core 6写的&#xff0c;在框上应该不会有什么问题&#xff0c;这是大背景。另外服务是部署在k8s上的&#xff0c;于是就和性能测试人员&#xff0c;开发人员搭测试环…

html单选框 点击取消选中,radio单选框再点击取消选中

html:html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">单选框选项a选项b选项c选项dcheckradio.js://参数&#xff1a;obj为当前点击的radio对象function onClickRadioStyle(obj){var…

开启AngularJS 1.X的学习之路(1)

概念(1) AngularJS 应用 AngularJS 模块&#xff08;Module&#xff09; 定义了 AngularJS 应用。AngularJS 控制器&#xff08;Controller&#xff09; 用于控制 AngularJS 应用。ng-app指令定义了应用, ng-controller 定义了控制器。eg: <div ng-app"myApp" ng-…

Hello boke!

Hello boke&#xff01;转载于:https://www.cnblogs.com/yikuan-919/p/9319071.html

ASP.NET Core在.NET 7 RC1中的更新

原文链接&#xff1a;https://devblogs.microsoft.com/dotnet/asp-net-core-updates-in-dotnet-7-rc-1/[1]原文作者&#xff1a;Daniel Roth翻译&#xff1a;沙漠尽头的狼(谷歌翻译加持).NET 7 Release Candidate 1 (RC1) 现已推出[2]&#xff0c;其中包括对 ASP.NET Core 的许…

html5 tab菜单切换页面,11个常用的jQuery TAB切换菜单源码及制作教程

11个常用的jQuery TAB切换菜单源码及制作教程SponsorTAB切换式菜单可以方便为我们减少很多网页布局空间&#xff0c;而且用jQuery的话可以加入一些动画效果&#xff0c;比如渐变&#xff0c;向左右滑动等&#xff0c;提升一定的用户体验&#xff0c;所以TAB菜单目前来说是很流行…

7.16 10.19-10.22

10.19 iptables规则备份和恢复[roothyc-01-01 ~]# service iptables save 保存iptables规则该命令会将规则保存在/etc/sysconfig/iptables将iptables规则备份到一个文件中[roothyc-01-01 ~]# iptables-save>/tmp/ipt.txt将iptables规则备份到ipt.txt文件中从备份规则的文件恢…