【并发】共享模型之管程

2024-01-14 17:44
文章标签 模型 并发 共享 管程

本文主要是介绍【并发】共享模型之管程，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

共享模型之管程

共享问题

package 并发;public class Test1 {static int a=0;public static void main(String[] args) throws InterruptedException {Thread t1=new Thread(new Runnable() {@Overridepublic void run() {for(int i=0;i<5000;i++){a++;}}});Thread t2=new Thread(new Runnable() {@Overridepublic void run() {for(int i=0;i<5000;i++){a--;}}});t1.start();;t2.start();t1.join();;t2.join();System.out.println("a="+a);}}

与预期的结果不同

问题分析

以上的结果可能是正数，负数，0为什么呢？ 因为Java中对静态变量的自增，自减并不是原子操作，要彻底理解，必须从字节码进行分析。

例如：对于i++而言，实际会产生如下的JVM字节码指令：

getstatic i //获取静态变量 iconst_1 //准备常量1 iadd //自增 putstatic i //将修改后的值存入静态变量i

而JAVA 的内存模型如下，完成静态变量的自增，自减需要在主存和工作内存中进行数据交换：

如果是单线程，上面的代码是顺序执行(不会交错) 没有问题：

临界区

  • 一个程序运行多个线程本身是没有问题的。
  • 问题出在多个线程访问共享资源。
    • 多个线程读取共享资源其实也没有问题
    • 在多个线程对共享资源读写操作时发生指令交集，就会出现问题。
  • 一般代码块如果存在对共享资源的多线程读写操作。那么这段代码称为临界区。
Thread t1=new Thread(new Runnable() {@Overridepublic void run() {//临界区a++;}
});
Thread t2=new Thread(new Runnable() {@Overridepublic void run() {//临界区a--;}
});

解决方案

  • 阻塞式的解决方案：synchronized \ Lock
  • 非阻塞式的解决方案：原子变量

本次课程使用的解决方案式：synchronzied ，来解决上述问题,俗称【对象锁】。

它采用互斥的方式让同一时刻至多只有一个线程能持有【对象锁】，其他想获取这个对象锁就会被阻塞住，这样就能保证拥有锁的线程可以安全的执行临界区内的代码，不用担心上下文的切换。

注意：

虽然java中的互斥和同步都是可以采用synchronized来完成，但还是有区别的。

  • 互斥是保证临界区的竟态条件发生，同一时刻只有一个线程执行临界区的代码。
  • 同步是由于线程执行的先后，顺序不同，需要一个线程等待其他线程运行到这个点，

synchronzied

语法
synchronized(){  临界区
}
解决
package 并发;import java.util.Date;public class Test1 {static Integer a=0;static Object flag=new Object();public static void main(String[] args) throws InterruptedException {Thread t1=new Thread(new Runnable() {@Overridepublic void run() {for(int i=0;i<5000;i++){//加锁synchronized (flag){a++;}}}});Thread t2=new Thread(new Runnable() {@Overridepublic void run() {for(int i=0;i<5000;i++){//加锁synchronized (flag){a--;}}}});t1.start();;t2.start();t1.join();;t2.join();System.out.println("a="+a);}}
向对象思想改进面
package 并发;import java.util.Date;class Test1 {static Integer a=0;static   Room room=new Room();public static void main(String[] args) throws InterruptedException {Thread t1=new Thread(new Runnable() {@Overridepublic void run() {for(int i=0;i<5000;i++){room.increase();;}}});Thread t2=new Thread(new Runnable() {@Overridepublic void run() {for(int i=0;i<5000;i++){room.decrease();;}}});t1.start();;t2.start();t1.join();;t2.join();System.out.println("结果是"+room.count);}}class Room {public static int count=0;static Object flag=new Object();public void increase(){synchronized (flag){count++;}}public void decrease(){synchronized (flag){count--;}}}

方法上的synchronized

语法

synchronized加在普通方法上

class Room {public static int count=0;static Object flag=new Object();public synchronized void increase(){count++;}//等价于 锁住的是自己的对象public void increase(){synchronized(this){count++;}}}

synchronized加在静态方法上

class Room {public static int count=0;static Object flag=new Object();public synchronized  static void increase(){count++;}//等价于 锁住的是自己的类对象public static void increase(){synchronized(Room.class){count++;}}}

不加synchronized方法无法保证原子性

线程安全分析

成员变量和静态变量是否是安全的？

  • 如果他们没有共享，则线程安全
  • 如果他们被共享了，根据他们的线程是否能改变，又分为两种：

                只有读操作，则线程安全。

                如果有读写操作，则这段代码是临界区，需要考虑线程安全。

局部变量是否是线程安全的？

  • 局部变量是线程安全的
  • 但局部变量引用的对象未必。（堆中的变量就可能被共享）
    • 如果该对象没有逃离方法的作用范围，则是线程安全的。
    • 如果该对象逃离方法的作用范围，则需要考虑线程安全
局部变量线程安全分析

public static void test1(){ int i=10; i++; }

每个线程调用test1()方法时局部变量i，会在每个线程的栈帧内存中被创建多份，因此不存在共享

如图：

局部变量的引用稍有不同

先看一个成员变量的例子

class ThreadUnsafe { ArrayList list = new ArrayList<>(); public void method1(int loopNumber) { for (int i = 0; i < loopNumber; i++) { // { 临界区, 会产生竞态条件 method2(); method3();执行其中一种情况是，如果线程2 还未 add，线程1 remove 就会报错：Exception in thread "Thread1" java.lang.IndexOutOfBoundsException: Index: 0, Size: 0 at java.util.ArrayList.rangeCheck(ArrayList.java:657) at java.util.ArrayList.remove(ArrayList.java:496) at cn.itcast.n6.ThreadUnsafe.method3(TestThreadSafe.java:35) at cn.itcast.n6.ThreadUnsafe.method1(TestThreadSafe.java:26) at cn.itcast.n6.TestThreadSafe.lambda$main$0(TestThreadSafe.java:14) at java.lang.Thread.run(Thread.java:748)分析：无论哪个线程中的 method2 引用的都是同一个对象中的 list 成员变量method3 与 method2 分析相同 // } 临界区 } } private void method2() { list.add("1"); } private void method3() { list.remove(0); }}

执行

static final int THREAD_NUMBER = 2;
static final int LOOP_NUMBER = 200;
public static void main(String[] args) { ThreadUnsafe test = new ThreadUnsafe(); for (int i = 0; i < THREAD_NUMBER; i++) { new Thread(() -> { test.method1(LOOP_NUMBER); }, "Thread" + i).start(); }}

其中一种情况是，如果线程2 还未 add，线程1 remove 就会报错

Exception in thread "Thread1" java.lang.IndexOutOfBoundsException: Index: 0, Size: 0 at java.util.ArrayList.rangeCheck(ArrayList.java:657) at java.util.ArrayList.remove(ArrayList.java:496) at cn.itcast.n6.ThreadUnsafe.method3(TestThreadSafe.java:35) at cn.itcast.n6.ThreadUnsafe.method1(TestThreadSafe.java:26) at cn.itcast.n6.TestThreadSafe.lambda$main$0(TestThreadSafe.java:14) at java.lang.Thread.run(Thread.java:748)

分析：

无论哪个线程中的 method2 引用的都是同一个对象中的 list 成员变量

method3 与 method2 分析相同

这篇关于【并发】共享模型之管程的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/605993。

相关文章

大模型研发全揭秘：客服工单数据标注的完整攻略

大模型研发全揭秘：客服工单数据标注的完整攻略

在人工智能（AI）领域，数据标注是模型训练过程中至关重要的一步。无论你是新手还是有经验的从业者，掌握数据标注的技术细节和常见问题的解决方案都能为你的AI项目增添不少价值。在电信运营商的客服系统中，工单数据是客户问题和解决方案的重要记录。通过对这些工单数据进行有效标注，不仅能够帮助提升客服自动化系统的智能化水平，还能优化客户服务流程，提高客户满意度。本文将详细介绍如何在电信运营商客服工单的背景下进行
阅读更多...
Andrej Karpathy最新采访：认知核心模型10亿参数就够了，AI会打破教育不公的僵局

Andrej Karpathy最新采访：认知核心模型10亿参数就够了，AI会打破教育不公的僵局

夕小瑶科技说 原创  作者 | 海野 AI圈子的红人，AI大神Andrej Karpathy，曾是OpenAI联合创始人之一，特斯拉AI总监。上一次的动态是官宣创办一家名为 Eureka Labs 的人工智能+教育公司 ，宣布将长期致力于AI原生教育。 近日，Andrej Karpathy接受了No Priors（投资博客）的采访，与硅谷知名投资人 Sara Guo 和 Elad G
阅读更多...
Retrieval-based-Voice-Conversion-WebUI模型构建指南

Retrieval-based-Voice-Conversion-WebUI模型构建指南

一、模型介绍 Retrieval-based-Voice-Conversion-WebUI（简称 RVC）模型是一个基于 VITS（Variational Inference with adversarial learning for end-to-end Text-to-Speech）的简单易用的语音转换框架。 具有以下特点 简单易用：RVC 模型通过简单易用的网页界面，使得用户无需深入了
阅读更多...
透彻！驯服大型语言模型（LLMs）的五种方法，及具体方法选择思路

透彻！驯服大型语言模型（LLMs）的五种方法，及具体方法选择思路

引言 随着时间的发展，大型语言模型不再停留在演示阶段而是逐步面向生产系统的应用，随着人们期望的不断增加，目标也发生了巨大的变化。在短短的几个月的时间里，人们对大模型的认识已经从对其zero-shot能力感到惊讶，转变为考虑改进模型质量、提高模型可用性。 「大语言模型(LLMs)其实就是利用高容量的模型架构（例如Transformer）对海量的、多种多样的数据分布进行建模得到，它包含了大量的先验
阅读更多...
图神经网络模型介绍（1）

图神经网络模型介绍（1）

我们将图神经网络分为基于谱域的模型和基于空域的模型，并按照发展顺序详解每个类别中的重要模型。 1.1基于谱域的图神经网络         谱域上的图卷积在图学习迈向深度学习的发展历程中起到了关键的作用。本节主要介绍三个具有代表性的谱域图神经网络：谱图卷积网络、切比雪夫网络和图卷积网络。 （1）谱图卷积网络 卷积定理：函数卷积的傅里叶变换是函数傅里叶变换的乘积，即F{f*g}
阅读更多...
秋招最新大模型算法面试，熬夜都要肝完它

秋招最新大模型算法面试，熬夜都要肝完它

💥大家在面试大模型LLM这个板块的时候，不知道面试完会不会复盘、总结，做笔记的习惯，这份大模型算法岗面试八股笔记也帮助不少人拿到过offer ✨对于面试大模型算法工程师会有一定的帮助，都附有完整答案，熬夜也要看完，祝大家一臂之力 这份《大模型算法工程师面试题》已经上传CSDN，还有完整版的大模型 AI 学习资料，朋友们如果需要可以微信扫描下方CSDN官方认证二维码免费领取【保证100%免费
阅读更多...
【生成模型系列（初级）】嵌入（Embedding）方程——自然语言处理的数学灵魂【通俗理解】

【生成模型系列（初级）】嵌入（Embedding）方程——自然语言处理的数学灵魂【通俗理解】

【通俗理解】嵌入（Embedding）方程——自然语言处理的数学灵魂 关键词提炼 #嵌入方程 #自然语言处理 #词向量 #机器学习 #神经网络 #向量空间模型 #Siri #Google翻译 #AlexNet 第一节：嵌入方程的类比与核心概念【尽可能通俗】 嵌入方程可以被看作是自然语言处理中的“翻译机”，它将文本中的单词或短语转换成计算机能够理解的数学形式，即向量。 正如翻译机将一种语言
阅读更多...
怎么让1台电脑共享给7人同时流畅设计

怎么让1台电脑共享给7人同时流畅设计

在当今的创意设计与数字内容生产领域，图形工作站以其强大的计算能力、专业的图形处理能力和稳定的系统性能，成为了众多设计师、动画师、视频编辑师等创意工作者的必备工具。 设计团队面临资源有限，比如只有一台高性能电脑时，如何高效地让七人同时流畅地进行设计工作，便成为了一个亟待解决的问题。 一、硬件升级与配置 1.高性能处理器（CPU）：选择多核、高线程的处理器，例如Intel的至强系列或AMD的Ry
阅读更多...
高并发环境中保持幂等性

高并发环境中保持幂等性

在高并发环境中保持幂等性是一项重要的挑战。幂等性指的是无论操作执行多少次，其效果都是相同的。确保操作的幂等性可以避免重复执行带来的副作用。以下是一些保持幂等性的常用方法： 唯一标识符： 请求唯一标识：在每次请求中引入唯一标识符（如 UUID 或者生成的唯一 ID），在处理请求时，系统可以检查这个标识符是否已经处理过，如果是，则忽略重复请求。幂等键（Idempotency Key）：客户端在每次
阅读更多...
AI Toolkit + H100 GPU，一小时内微调最新热门文生图模型 FLUX

AI Toolkit + H100 GPU，一小时内微调最新热门文生图模型 FLUX

上个月，FLUX 席卷了互联网，这并非没有原因。他们声称优于 DALLE 3、Ideogram 和 Stable Diffusion 3 等模型，而这一点已被证明是有依据的。随着越来越多的流行图像生成工具（如 Stable Diffusion Web UI Forge 和 ComyUI）开始支持这些模型，FLUX 在 Stable Diffusion 领域的扩展将会持续下去。 自 FLU
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2