线程安全问题的原因与解决方案总结

news2025/7/8 14:49:35

目录

一 什么是线程安全?

二 线程安全问题的实例 

三 线程安全问题的原因

1.多个线程修改共享数据 

2.抢占式执行

3.修改操作不是原子的

4.内存可见性问题

5.指令重排序 

四 解决方案

1.同步代码块 

2.同步方法 

3.加锁lock解决问题 


一 什么是线程安全?

线程安全是指一个代码段或方法能够在多线程环境下正确地工作,即当多个线程同时访问共享资源(如变量、数据结构等)时,不会导致数据不一致或其他异常行为。具体来说,如果一段代码在被多个线程并发执行时,能够保证程序状态的一致性,避免出现竞态条件、死锁、数据损坏等问题,那么这段代码就是线程安全的。

二 线程安全问题的实例 

public class Demo {
    // 定义一个静态变量 count,初始值为 0。
    // 静态变量属于类,所有实例共享同一个静态变量。
    private static int count = 0;

    public static void main(String[] args) throws InterruptedException {
        // 创建第一个线程 t1,使用 Lambda 表达式定义线程任务。
        Thread t1 = new Thread(() -> {
            // 在 t1 线程中执行一个循环,循环 10000 次。
            for (int i = 0; i < 10000; i++) {
                // 每次循环对静态变量 count 进行自增操作。
                count++;
            }
        });

        // 创建第二个线程 t2,同样使用 Lambda 表达式定义线程任务。
        Thread t2 = new Thread(() -> {
            // 在 t2 线程中执行一个循环,循环 10000 次。
            for (int i = 0; i < 10000; i++) {
                // 每次循环对静态变量 count 进行自增操作。
                count++;
            }
        });

        // 启动线程 t1,t1 开始执行。
        t1.start();

        // 启动线程 t2,t2 开始执行。
        t2.start();

        // 调用 t1.join(),主线程会等待 t1 执行完毕后再继续执行。
        t1.join();

        // 调用 t2.join(),主线程会等待 t2 执行完毕后再继续执行。
        t2.join();

        // 打印最终的 count 值。
        // 注意:由于 count++ 操作不是线程安全的,可能会出现竞争条件(Race Condition),
        // 导致最终的 count 值小于预期的 20000。
        System.out.println(count);
    }
}

运行结果: 

count++ 实际上是三个步骤的组合:读取 count 的值、将其加 1、再写回 count。由于这些操作不是原子性的,在多线程环境下可能会导致问题。例如,两个线程可能同时读取到 count 的旧值,各自加 1 后再写回,结果只会增加 1 而不是 2。因此,最终的 count 值可能小于预期的 20000。这就是多线程导致的线程安全问题。

三 线程安全问题的原因

1.多个线程修改共享数据 

当两个或更多的线程试图同时访问和修改同一个资源时,可能会导致竞态条件。例如,一个线程正在读取某个值的同时,另一个线程可能正在修改这个值,这会导致不可预测的结果。 

2.抢占式执行

3.修改操作不是原子的

原子性:指的是一个操作要么完全执行,要么完全不执行,中间状态对外不可见。

无论是在单核还是多核环境中,具有原子性的操作在同一时刻只能由一个线程完成,从而避免了多线程并发访问导致的数据不一致问题。

简单来说,如果一个操作在执行过程中不会被其他线程干扰,就可以认为它具有原子性。例如,在Java中,a=1这样的简单赋值操作(针对基本数据类型,除了long和double)通常被认为是原子性操作,而像a++或a+=1这样的复合操作则不是原子性的,因为它们涉及读取、修改和写入的多个步骤,可能被线程调度打断。

Java中的原子性操作包括:

  1. 基本类型简单赋值操作:对于除longdouble之外的基本数据类型(如int, boolean等),简单的读取和赋值操作是原子性的。但是,这并不包括复合操作,例如a++a += 1

  2. 所有引用reference的赋值操作。

  3. java.concurrent.Atomic.* 包中所有类的一切操作

4.内存可见性问题

可见性的定义:可见性指的是在多线程环境下,当多个线程访问同一个变量时,一个线程对这个变量所做的修改能够立即被其他线程所察觉。具体来说,如果一个线程修改了共享变量的值,其他线程应该能够即时看到这一变化。然而,在默认情况下,一个线程对共享变量的操作对于其他线程来说可能是不可见的,因为每个线程可能会缓存变量的副本,或者编译器和处理器为了优化性能而重新排序指令。Java提供了volatile关键字来确保变量修改的可见性。当一个共享变量被声明为volatile后,它就成为了所有读写操作都直接与主内存交互的标志。

5.指令重排序 

有序性的定义:有序性指的是程序执行顺序是否按照代码的书写顺序进行。理想情况下,程序应该严格按照代码的先后顺序执行操作,但在实际中,为了提高性能,编译器和处理器可能会对指令进行重排序。 

 Java内存模型中的有序性可以总结为:如果在本线程内观察,所有操作都是有序的;如果在一个线程中观察另一个线程,所有操作都是无序的。前半句是指“线程内表现为串行语义”,后半句是指“指令重排序”现象和“工作内存主主内存同步延迟”现象。
        在Java内存模型中,为了效率是允许编译器和处理器对指令进行重排序,当然重排序不会影响单线程的运行结果,但是对多线程会有影响。Java提供volatile来保证一定的有序性。最著名的例子就是单例模式里面的DCL(双重检查锁)。另外,可以通过synchronized和Lock来保证有序性,synchronized和Lock保证每个时刻是有一个线程执行同步代码,相当于是让线程顺序执行同步代码,自然就保证了有序性。 

四 解决方案

为了解决多线程环境下同时操作共享数据引发的线程安全问题,我们通常采用同步机制(通过synchronized关键字实现)。同步的核心思想是将涉及共享数据的操作视为一个不可分割的整体,确保当一个线程在执行这段代码时,其他线程无法对其进行访问,直到当前线程完成操作。

同步方案主要可以通过以下三种方式实施,每种方式使用的锁对象各不相同:。

1.同步代码块 

格式:

synchronized(对象){

        代码块;

public class Demo {
    private static int count = 0;
    private static final Object lock = new Object(); // 使用 final 防止锁对象被修改

    public static void main(String[] args) throws InterruptedException {
        // 创建两个线程
        Thread t1 = new Thread(() -> {
            synchronized (lock) {
                for (int i = 0; i < 10000; i++) {
                    count++;
                }
            }
        });

        Thread t2 = new Thread(() -> {
            synchronized (lock) {
                for (int i = 0; i < 10000; i++) {
                    count++;
                }
            }
        });

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

        // 等待两个线程执行完毕
        t1.join();
        t2.join();

        // 打印最终结果
        System.out.println("Final Count: " + count);
    }
}

运行结果: 

2.同步方法 

public class Demo2 {
    public static int count = 0;
    public static synchronized void inCrease() {
        for (int i = 0; i < 10000; i++) {
            count++;
        }
    }
    public static void main(String[] args) {
        Thread t1 = new Thread(() -> {
            inCrease();
        });
        Thread t2 = new Thread(() -> {
            inCrease();
        });
        t1.start();
        t2.start();
        try {
            t1.join();
            t2.join();
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        System.out.println("Final Count:" + count);
    }

}

运行结果:

3.加锁lock解决问题 

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class Demo3 {
    public static int count = 0;
    public static Lock lock = new ReentrantLock();

    public static void inCrease() {
        lock.lock(); // 获取锁
        try {
            for (int i = 0; i < 10000; i++) {
                count++; // 对共享变量进行操作
            }
        } finally {
            lock.unlock(); // 确保锁一定会被释放
        }
    }

    public static void main(String[] args) {
        Thread t1 = new Thread(() -> {
            inCrease();
        });
        Thread t2 = new Thread(() -> {
            inCrease();
        });

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

        try {
            t1.join(); // 等待 t1 完成
            t2.join(); // 等待 t2 完成
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }

        System.out.println("Final Count: " + count); // 输出最终结果
    }
}

运行结果: 

本期到这了先,下期见! 

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

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

相关文章

Tunable laser激光器的前向和后向锁波长方案

----转载自秦岭农民的文章 Tunable laser可调激光器的锁波长方案 激光器锁波长技术是指通过各种手段将激光器的输出波长稳定在某一特定值或范围内&#xff0c;以满足高精度应用的需求。这些技术包括Etalon、波长计/光谱仪反馈、波长参考源、温度控制、电流控制、锁相环&#…

蓝桥杯:日期统计

文章目录 问题描述解法一递归解法二&#xff1a;暴力破解 问题描述 首先我们要了解什么是子序列&#xff0c;就是一个序列之中可以忽略元素但是不能改变顺序之后获得的序列就叫做子序列。 如"123"就是"11234"的子序列而不是"11324"的子序列 解法…

IQ解调原理#通信原理系列

IQ解调原理&#xff1a;接收端收到s(t)信号后&#xff0c;分为两路&#xff1a; 一路信号乘以cosω₀t再积分&#xff0c;就可以得到a&#xff1a; 另一路乘以 -sinω₀t再积分&#xff0c;就可以得到b&#xff1a;

C++蓝桥杯实训篇(三)

片头 嗨&#xff01;小伙伴们&#xff0c;大家好~ 今天我们来学习前缀和与差分相关知识&#xff0c;准备好了吗&#xff1f;咱们开始咯&#xff01; 一、一维前缀和 以上&#xff0c;是我们用数学知识求解区间和&#xff0c;现在我们使用前缀和来求解&#xff1a; 我们知道&am…

【数据挖掘】岭回归(Ridge Regression)和线性回归(Linear Regression)对比实验

这是一个非常实用的 岭回归&#xff08;Ridge Regression&#xff09;和线性回归&#xff08;Linear Regression&#xff09;对比实验&#xff0c;使用了 scikit-learn 中的 California Housing 数据集 来预测房价。 &#x1f4e6; 第一步&#xff1a;导入必要的库 import num…

CExercise_07_1指针和数组_1编写函数交换数组中两个下标的元素

题目&#xff1a; 要求编写函数将数组作为参数传递来实现&#xff1a; 1.编写函数交换数组中两个下标的元素。函数声明如下&#xff1a;void swap(int *arr, int i, int j) 。要求不使用[]运算符&#xff0c;将[]还原成解引用运算符和指针加法来完成。 关键点 通过指针交换数组…

塔能科技:智能路灯物联运维产业发展现状与趋势分析

随着智慧城市建设的推进&#xff0c;智能路灯物联运维产业正经历快速发展&#xff0c;市场规模持续扩大。文章探讨了智能路灯物联运维的技术体系、市场机遇和挑战&#xff0c;并预测了未来发展趋势&#xff0c;为行业发展提供参考。 关键词 智能路灯&#xff1b;物联运维&#…

ZW3D二次开发_普通对话框_设置对话框弹出位置

ZW3D的普通对话框可以在UI设计时静态地设置对话框弹出的位置&#xff0c;方法如下&#xff1a; 选中对话框的最顶级对象&#xff0c;即ZsCc::Form对象&#xff0c;在属性管理器中添加一个动态属性“form_pos”&#xff0c;类型为“StringList”&#xff0c;如下图所示 不同属性…

低代码开发「JNPF」应用场景

政务系统快速搭建 在数字化政务转型的浪潮下&#xff0c;JNPF 快速开发平台扮演着关键角色&#xff0c;为政府部门提供了高效且便捷的审批流程自动化解决方案。 以 “一网通办” 为例&#xff0c;通过平台的可视化拖拽式配置功能&#xff0c;政府工作人员能够将原本复杂繁琐的…

欧拉函数模板

1.欧拉函数模板 - 蓝桥云课 问题描述 这是一道模板题。 首先给出欧拉函数的定义&#xff1a;即 Φ(n) 表示的是小于等于 n 的数中和 n 互质的数的个数。 比如说 Φ(6)2&#xff0c;当 n 是质数的时候&#xff0c;显然有 Φ(n)n−1。 题目大意&#xff1a; 给定 n 个正整数…

屏幕空间反射SSR-笔记

屏幕空间反射SSR 相关文章&#xff1a; [OpenGL] 屏幕空间反射效果 Games202-RealTime GI in Screen Space github上的例子&#xff0c;使用visual studio2019 github例子对应的文章 使用OpenGL和C实现发光柱子的SSR倒影 下面是一个使用OpenGL和C实现屏幕空间反射(SSR)来创建…

动态规划算法深度解析:0-1背包问题(含完整流程)

简介&#xff1a; 0-1背包问题是经典的组合优化问题&#xff1a;给定一组物品&#xff08;每个物品有重量和价值&#xff09;&#xff0c;在背包容量限制下选择物品装入背包&#xff0c;要求总价值最大化且每个物品不可重复选取。 动态规划核心思想 通过构建二维状态表dp[i]…

LeetCode刷题SQL笔记

系列博客目录 文章目录 系列博客目录1.distinct关键字 去除重复2.char_length()3.group by 与 count()连用4.date类型有个函数datediff()5.mod 函数6.join和left join的区别1. **JOIN&#xff08;内连接&#xff0c;INNER JOIN&#xff09;**示例&#xff1a; 2. **LEFT JOIN&a…

循环神经网络 - 参数学习之随时间反向传播算法

本文中&#xff0c;我们以同步的序列到序列模式为例来介绍循环神经网络的参数学习。 循环神经网络中存在一个递归调用的函数 &#x1d453;(⋅)&#xff0c;因此其计算参数梯度的方式和前馈神经网络不太相同。在循环神经网络中主要有两种计算梯度的方式&#xff1a;随时间反向…

球类(继承和多态)

父类Ball&#xff0c;设置为抽象类&#xff0c;调用get和set方法创建对象&#xff0c;将子类重写的功能函数抽象化。 // 抽象球类 abstract class Ball {private String name;private double radius; // 半径private double weight; // 重量private double price; // 价格// 构…

DFS和BFS的模版

dfs dfs金典例题理解就是走迷宫 P1605 迷宫 - 洛谷 dfs本质上在套一个模版&#xff1a; ///dfs #include<bits/stdc.h> using namespace std; int a[10][10]{0}; int m,n,t,ans0; int ex,ey; int v[10][10]{0}; int dx[4]{-1,0,1,0}; int dy[4]{0,1,0,-1}; void dfs(in…

Ansible Playbook 进阶探秘:Handlers、变量、循环及条件判断全解析

192.168.60.100ansible.com192.168.60.110 client-1.com 192.168.60.120client-2.com192.168.60.130client-1.com 一、Handlers 介绍&#xff1a;在发生改变时执行的操作(类似puppet通知机制) 示例&#xff1a; 当apache的配置文件发生改变时&#xff0c;apache服务才会重启…

MATLAB的24脉波整流器Simulink仿真与故障诊断

本博客来源于CSDN机器鱼&#xff0c;未同意任何人转载。 更多内容&#xff0c;欢迎点击本专栏目录&#xff0c;查看更多内容。 目录 0 引言 1 故障数据采集 2 故障特征提取 3 故障诊断分类 4 结语 本博客内容是在MATLAB2023下完成。 0 引言 对于电力电子电路的故障诊断…

linux第三次作业

1、将你的虚拟机的网卡模式设置为nat模式&#xff0c;给虚拟机网卡配置三个主机位分别为100、200、168的ip地址 2、测试你的虚拟机是否能够ping通网关和dns&#xff0c;如果不能请修改网关和dns的地址 3、将如下内容写入/etc/hosts文件中&#xff08;如果有多个ip地址则写多行&…

国标GB28181视频平台EasyCVR顺应智慧农业自动化趋势,打造大棚实时视频监控防线

一、方案背景 近年来&#xff0c;温室大棚种植技术凭借其显著的优势&#xff0c;在提升农作物产量和质量、丰富农产品供应方面发挥了重要的作用&#xff0c;极大改善了人们的生活水平&#xff0c;得到了广泛的推广和应用。大棚内的温度、湿度、光照度和二氧化碳浓度等环境因素…