使用synchronized关键字同步Java线程

问题

在Java多线程编程中,你需要保护某些数据,防止多个线程同时访问导致数据不一致或程序错误。

解决方案

在需要保护的方法或代码段上使用synchronized关键字。

讨论

synchronized关键字是Java提供的同步机制,用于确保在同一时刻只有一个线程能够执行指定的方法或代码块。这种机制特别适用于保护共享资源,防止多线程并发访问引发的问题。以下是synchronized的主要功能:

  • 对于实例方法synchronized限制同一对象实例中只有一个线程可以执行该方法或其他同步方法。
  • 对于静态方法synchronized限制同一类中只有一个线程可以执行该方法。
  • 对于代码块,可以通过synchronized(object)指定锁定某个对象,只保护特定的代码段。

同步整个方法实现起来更简单且更安全,但可能会因阻塞其他线程而影响性能。如果只需要保护部分代码,可以使用同步代码块以提高效率。

示例:同步方法

以下是一个简单的线程安全列表添加操作示例:

public class SafeList {private Object[] data;private int max = 0;public SafeList(int size) {data = new Object[size];}public synchronized void add(Object obj) {data[max] = obj;max = max + 1;}
}

在这个例子中,add()方法被synchronized修饰,确保同一时刻只有一个线程可以修改data数组,避免数据覆盖或丢失。

未同步的风险

假设我们去掉synchronized,如下:

public void add(Object obj) {data[max] = obj;  // 第一步:存储对象max = max + 1;    // 第二步:递增索引
}

如果线程A在执行第一步后被中断,线程B紧接着运行并执行两步,会覆盖线程A存储的对象。线程A恢复后继续执行第二步,导致max指向一个未初始化的位置。这种情况可能导致数据丢失和数组状态不一致,如下图所示:

正常情况:
data[max] = obj; max = 1;失败情况:
线程A: data[0] = obj1;
线程B: data[0] = obj2; max = 1;
线程A: max = 2; // obj1丢失,data[1]未初始化

即使将两行合并为data[max++] = obj;,问题依然存在,因为线程可能在JVM指令之间被中断。只有使用synchronized才能彻底解决问题。

示例:同步代码块

如果只想同步部分代码,可以使用synchronized代码块。例如:

public class SafeList {private Object[] data;private int max = 0;public SafeList(int size) {data = new Object[size];}public void add(Object obj) {synchronized (data) {data[max] = obj;max = max + 1;}}
}

这里,synchronized (data)确保对data数组的访问是线程安全的,同时未同步的代码(如构造函数)不会阻塞其他线程。

选择同步对象

同步代码块需要指定一个对象作为锁。通常选择与共享资源相关的对象,例如:

  • synchronized(this):锁定当前对象实例。
  • synchronized(data):锁定共享数组。
  • 自定义锁对象:如private final Object lock = new Object();

例如,同步对ArrayList的访问:

public class ListManager {private ArrayList<String> myList = new ArrayList<>();public void process(String item) {synchronized (myList) {if (myList.indexOf(item) != -1) {System.out.println("Item found!");} else {myList.add(item);}}}
}

示例:多线程数组操作

以下代码展示了同步与非同步操作的对比:

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ArrayAdding {private static final int HOWMANY = 1000;private static int[] array;private static ExecutorService pool = Executors.newFixedThreadPool(2);static Runnable runBad = () -> {for (int i = 0; i < array.length; i++) {array[i] = array[i] + i;}};static Runnable runGood = () -> {synchronized (array) {for (int i = 0; i < array.length; i++) {array[i] = array[i] + i;}}};public static void main(String[] args) throws Exception {process("runGood", runGood);process("runBad", runBad);}static void process(String name, Runnable run) throws Exception {System.out.println("Starting: " + name);array = new int[HOWMANY];var t1 = pool.submit(run);var t2 = pool.submit(run);t1.get();t2.get();for (int i = 0; i < array.length; i++) {if (array[i] != 2 * i) {System.out.printf("%d found at offset %d\n", array[i], i);return;}}System.out.println(name + " completed successfully");}
}

运行结果可能如下:

Starting: runGood
runGood completed successfully
Starting: runBad
468 found at offset 468

runGood使用同步,始终正确;runBad未同步,可能因竞态条件失败。这种失败在现实中可能导致严重后果,如Therac-25事件中的辐射治疗事故。

结论

synchronized关键字是Java中保护数据免受多线程并发访问的有效工具。通过同步方法或代码块,可以防止数据不一致和竞态条件。选择同步整个方法还是代码块取决于性能和安全性的权衡。合理的同步设计能显著提升程序的可靠性。

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

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

相关文章

MATLAB基于格拉姆角场与2DCNN-BiGRU的轴承故障诊断模型

本博客来源于CSDN机器鱼&#xff0c;未同意任何人转载。 更多内容&#xff0c;欢迎点击本专栏目录&#xff0c;查看更多内容。 目录 0 引言 1 格拉姆角场原理 2 2DCNN-BiGRU网络结构 3 应用实例 3.1 数据准备 3.2 格拉姆角场数据提取 3.3 网络模型搭建-重中之重 3.4 …

电气设备器件选型参数---断路器

断路器 一、基本电气参数 额定电压&#xff08;Ue&#xff09; 必须≥系统最高工作电压&#xff08;如380V、660V等&#xff09;。 注意直流/交流系统的区别&#xff0c;直流断路器需专门设计。 额定电流&#xff08;In&#xff09; 根据负载的持续工作电流选择&#xff0c;…

Linux常用命令30——groupadd创建新的用户组

在使用Linux或macOS日常开发中&#xff0c;熟悉一些基本的命令有助于提高工作效率&#xff0c;groupadd命令的功能是创建新的用户组。每个用户在创建时都有一个与其同名的基本组&#xff0c;后期可以使用groupadd命令创建出新的用户组信息&#xff0c;让多个用户加入指定的扩展…

微信小程序 自定义组件 标签管理

环境 小程序环境&#xff1a; 微信开发者工具&#xff1a;RC 1.06.2503281 win32-x64 基础运行库&#xff1a;3.8.1 概述 基础功能 标签增删改查&#xff1a;支持添加/删除单个标签、批量删除、重置默认标签 数据展示&#xff1a;通过对话框展示结构化数据并支持复制 动…

wpf CommandParameter 传递MouseWheelEventArgs参数 ,用 MvvmLight 实现

在 WPF 中使用 MVVM Light 框架传递 MouseWheelEventArgs 参数至 CommandParameter,可通过以下步骤实现: ‌1. XAML 中配置事件绑定‌ 在控件上通过 EventToCommand 绑定鼠标滚轮事件,并启用 PassEventArgsToCommand 属性以传递事件参数: <!-- 命名空间声明 --> x…

vmware diffy配置ollama 本机ip无法访问

防火墙直接关闭 本地测试&#xff0c;给它直接关了 ollama配置 vim /etc/systemd/system/ollama.service这是的配置 [Unit] DescriptionOllama Service Afternetwork-online.target[Service] Environment"OLLAMA_HOST0.0.0.0:11434" #Environment"OLLAMA_OR…

React--》掌握react构建拖拽交互的技巧

在这篇文章中将深入探讨如何使用react-dnd&#xff0c;从基础的拖拽操作到更复杂的自定义功能带你一步步走向实现流畅、可控且用户友好的拖拽体验,无论你是刚接触拖拽功能的初学者还是想要精细化拖拽交互的经验开发者&#xff0c;都能从中找到适合自己的灵感和解决方案。 目录 …

数据结构与算法:回溯

回溯 先给出一些leetcode算法题&#xff0c;以后遇见了相关题目再往上增加 主要参考代码随想录 2.1、组合问题 关于去重&#xff1a;两种写法的性能分析 需要注意的是&#xff1a;使用set去重的版本相对于used数组的版本效率都要低很多&#xff0c;大家在leetcode上提交&#x…

iview 分页改变每页条数时请求两次问题

问题 在iview page分页的时候&#xff0c;修改每页条数时&#xff0c;会发出两次请求。 iview 版本是4.0.0 原因 iview 的分页在调用on-page-size-change之前会调用on-Change。默认会先调用on-Change回到第一页&#xff0c;再调用on-page-size-change改变分页显示数量 此时就会…

一周学会Pandas2 Python数据处理与分析-Pandas2复杂数据查询操作

锋哥原创的Pandas2 Python数据处理与分析 视频教程&#xff1a; 2025版 Pandas2 Python数据处理与分析 视频教程(无废话版) 玩命更新中~_哔哩哔哩_bilibili 前面我们学了.loc[]等几个简单的数据筛选操作&#xff0c;但实际业务需求往 往需要按照一定的条件甚至复杂的组合条件…

【Vue bug】:deep()失效

vue 组件中使用了 element-plus 组件 <template><el-dialog:model-value"visible":title"title":width"width px":before-close"onClose"><div class"container" :style"{height:height px}"&g…

Trae 安装第三方插件支持本地部署的大语言模型

Trae 安装第三方插件支持本地部署的大语言模型 0. 引言1. 安装插件 0. 引言 字节发布的 Trae IDE 一直不支持本地部署的的大语言模型。 Qwen3 刚刚发布&#xff0c;想在 Trae 中使用本地部署的 Qwen3&#xff0c;我们可以在 Trae 中安装其他插件。 1. 安装插件 我们可以安装…

JavaScript 中的 Proxy 与 Reflect 教程

目录 get 和 set 捕获器详解 为什么要用 Reflect? 使用语法间接调用内部方法 使用 Reflect 直接调用内部方法 对比总结: Reflect API 及其与 Proxy 的配合 Proxy 的典型应用场景 Proxy 是 ES6 引入的一种元编程特性。它允许创建一个代理对象来包装目标对象,并拦截对目标…

基于STM32的心电图监测系统设计

摘要 本论文旨在设计一种基于 STM32 微控制器的心电图监测系统&#xff0c;通过对人体心电信号的采集、处理和分析&#xff0c;实现对心电图的实时监测与显示。系统采用高精度的心电信号采集模块&#xff0c;结合 STM32 强大的数据处理能力&#xff0c;能够有效去除噪声干扰&a…

C语言----操作符详解(万字详解)

目录 1. 操作符的分类 2. 二进制和进制转换 3. 原码 反码 补码 4. 移位操作符 4.1 左移操作符 >> 4.2 右移操作符 >> 5. 位操作符 5.1 按位与 & 5.2 按位或 | 5.3 按位异或 ^ 5.4 按位取反 ~ 练习 整数存储在内存中二进制中1的个数 练习 二进制位…

【进阶】C# 委托(Delegate)知识点总结归纳

1. 委托的基本概念 定义&#xff1a;委托是一种类型安全的函数指针&#xff0c;用于封装方法&#xff08;静态方法或实例方法&#xff09;。 核心作用&#xff1a;允许将方法作为参数传递&#xff0c;实现回调机制和事件处理。 类型安全&#xff1a;委托在编译时会检查方法签…

WebRTC 服务器之Janus视频会议插件信令交互

1.基础知识回顾 WebRTC 服务器之Janus概述和环境搭建-CSDN博客 WebRTC 服务器之Janus架构分析-CSDN博客 2.插件使用流程 我们要使⽤janus的功能时&#xff0c;通常要执⾏以下操作&#xff1a; 1. 在你的⽹⻚引入 Janus.js 库&#xff0c;即是包含janus.js&#xff1b; <…

Go语言中的无锁数据结构与并发效率优化

1. 引言 在高并发系统开发中&#xff0c;性能瓶颈往往出现在并发控制上。作为一个有着10年Go开发经验的后端工程师&#xff0c;我见证了无数因锁竞争导致的性能问题&#xff0c;也亲历了无锁编程为系统带来的巨大提升。 传统的锁机制就像是十字路口的红绿灯——虽然能确保安全…

STM32部分:2、环境搭建

飞书文档https://x509p6c8to.feishu.cn/wiki/DQsBw76bCiWaO4kS8TXcWDs0nAh Keil MDK用于编写代码&#xff0c;编译代码芯片支持包&#xff0c;用于支持某类芯片编程支持STM32CubeMX用于自动生成工程&#xff0c;减少手动重复工作 STM32F1系列芯片支持包 软件下载 直接下载&am…

U3D工程师简历模板

模板信息 简历范文名称&#xff1a;U3D工程师简历模板&#xff0c;所属行业&#xff1a;其他 | 职位&#xff0c;模板编号&#xff1a;B29EPQ 专业的个人简历模板&#xff0c;逻辑清晰&#xff0c;排版简洁美观&#xff0c;让你的个人简历显得更专业&#xff0c;找到好工作。…