【并发编程-1】多线程与并发设计

news2025/1/12 7:49:09

多线程介绍:

1、基础回顾:

线程状态:

  • NEW-新建:创建了线程对象,还未开始执行。
  • RUNNABLE-运行:线程对象已在java虚拟机运行,分为就绪(Ready)和运行中(Running)。
  • BLOCKED-阻塞:等待获取锁的状态。
  • WAITING-等待:在等待另一个线程的动作。 比如,线程调用了wait()后,等待另一个线程的notify()。
  • TIME_WAITING-限时等待:同上,只不过有时间限制。
  • TERMINATED-完成:线程已执行完成。

Thread、Runnable、Callable:

  • Runnable接口只是定义了一个run()方法,当线程执行start()时,会调用该方法。 所以,Thread类其实也是实现了Runnable。 
  • Runnable需要传入Thread中使用,thread的run方法也是调用runnable的run方法。所以,将同一个runnable对象传入不同的thread,可以共享runnable中的资源; 
  • Callable:同Runnable相似,要传到thread中执行,但是可以拿到返回值。

Thread常用api:

  • 获取和设置对象本身的信息:
    • getId() :返回 Thread对象的标识符。
    • getName()/setName():获取或设置Thread对象的名称。
    • isDaemon()/setDaemon():获取或建立Thread 对象的守护条件。
    • getPriority()/setPriority():获取或设置Thread对象的优先级。
    • getState():该方法返回Thread对象的状态。

  • sleep(): 主动挂起ms时间,不会让出cpu;

  • wait是Object方法,obj.wait(),则当前线程会假如obj对象的等待队列中,直到被唤醒。   所以多个线程在操作obj对象时,必须获取obj的锁,wait和notify要处于同步块中。
  • yeild(): 当然线程让出cpu资源给其他线程执行(不一定谦让成功)。
  • interrupt():中断目标线程,其实只是把线程的一个变量设置为true,并不能真正中断线程。 至于要不要被中断,要看目标线程本身的逻辑,比如:
    • 目标线程中可以调用interrupted方法判断,如果有了中断标记,就执行return退出。
    • 假如有了中断标记,目标线程在调用阻塞方法如wait、join、sleep等方法时,会抛出InterruptedException异常,需要正确处理这些异常(比如catch异常并退出)。
  • interrupted():判断目标线程是否被中断,但是将清除线程的中断标记。
  • isinterrupted():判断目标线程是否被中断,不会清除中断标记。
  • join() :暂停线程的执行。比如调用t1.join(),则暂停当前线程,直到t1线程执行完成。
    • 如过调用多个线程的join方法,多个线程互不影响,并行执行,只是当前线程要先等多个线程都执行完。
  • currentThread(): Thread 类的静态方法,返回执行当前代码的 Thread 对象。

2、synchronized

对象锁以下两种:

    public void method1() {
        synchronized (this) {
        }
    }
    
    public void synchronized method1(){
        
    }

类锁:

    public static void method2() {
        synchronized (MyClass.class) {

        }
    }

    public static void synchronized method2() {

    }

锁的本质,就是保证共享资源,在同一时间只能有一个线程可以访问。

锁的原理,就是在对象的内部有个标志(state:0-没有被占用;1-被某个线程占用),如果被占用就记录该线程的id。 此外,对象还维护了一个list,记录所有等待锁的线程id,锁释放后,就从list中取一个线程唤醒。

3、wait和notify 

 

一个内存队列,多个生产者在存放数据,多个消费者在读取数据。要实现这样的模型,就要做到几件事:

  1. 内存队列本身要加锁,才能实现线程安全。
  2.  阻塞。当内存队列满了,生产者放不进去时,会被阻塞;当内存队列是空的时候,消费者无事可做,会被阻塞。
  3. 双向通知。消费者被阻塞之后,生产者放入新数据,要notify()消费者;反之,生产者被阻塞之后,消费者消费了数据,要notify()生产者。

当然了,第二和第三,可以用其他方法,比如自己沉睡一段时间后重试,但是这样效率低且不实时。所以可以用 wait 和 notify,实现阻塞和通知。

问题:

1、为什么wait() 和 notify() 是Object的函数,而不是作为Thread自己的函数?

因为多个线程针对的是资源本身,也就是锁的对象。上面也说了,synchronized锁的对象内,记录了获取锁的线程id 和 所有等待的线程列表。所以,只能由资源对象去决定,应该阻塞 和 唤醒 哪个线程。

2、为什么wait 和 notify 必须和synchronized一起使用?

两个线程之间要通信,对于同一个对象来说,一个线程调用该对象的wait(),另一个线程调用该对象的notify(),该对象本身就需要同步!

3、为什么wait的时候必须释放锁?

因为wait的时候会进入阻塞状态,这时候还在synchronized中,其他线程也无法获取对象锁 调用notify,就会发生死锁。

4、notify 和 notifyall的区别?

notify是唤醒一个; notifyall是唤醒所有;  尽量使用notifyall,因为notify唤醒的那一个,可能无法正常使用了,就没有办法获取锁继续往下走,然后唤醒其他的,导致死锁。

5、为什么wait方法要在while循环内? 使用if可以吗?

当线程调用wait进入等待,然后在下一次被唤醒并获取到锁后,还要执行后续代码。 那么,在执行后续代码前,还需要再次判断,是否要重新wait。  如果使用if,被唤醒后一定会执行后续代码,可能会出问题。

4、线程关闭

不要stop和destory,原因很简单,如果强制杀死线程,则线程中所使用的资源,例如文件描述符、网络连接等无法正常关闭。

因此,一个线程一旦运行起来,不要强行关闭,合理的做法是让其运行完(方法执行完成),干净地释放掉所有资源,然后退出。如果是一个不断循环运行的线程,就需要用到线程间的通信机制,让主线程通知其退出。

5、守护线程 

线程分为守护线程和用户线程,调用某个线程的setDaemon(true)方法,就会将其设置为守护线程。 

当所有的用户线程退出后,整个JVM进程就会退出,而不会在乎守护线程的状态。   而守护线程会在主线程退出后,自动退出。  因此,守护线程一般可以用来监控用户线程来做事,

比如一些后台任务,定时任务,监听器,垃圾回收器等,就是用的守护线程。

并发概念: 

1、并发与并行:

并发:在一个处理器上快速切换多个任务,看起来像是同时运行。

并行:在不同的处理器、计算机上同时运行多个任务。

 2、同步:

简单说就是同一时间内,只能有一个执行。 

3、不可变对象: 

初始化后,不能修改其可是状态(比如它的属性值)。 就像Strign类,如果给它赋新的值,其实会创建另一个新对象。

因此,不可变对象是线程安全的。

并发问题: 

1、数据竞争:多个线程对一个非同步的数据,同时操作,可能造成不同的结果

2、死锁: 两个或两个以上的线程在执行过程中,由于竞争资源或者由于彼此通信而造成的一种阻塞的现象,若无外力作用,会永远的阻塞下去。

3、活锁:任务或者执行者没有被阻塞,但是由于某些条件没有满足,导致一直重复尝试—失败—尝试—失败的过程。

4、资源不足:多个线程等待某一资源的释放,然后选择下一个线程执行该资源。 但是可能由于系统没有涉及良好的算法等因素,导致资源不足,这些线程长时间等待下去。  所以,在等待时需要加入时间考虑。 

5、优先权反转:并发时,可能低优先权的任务先获取到资源,就会在高优先权的任务前执行。

JMM内存模型: 

jmm为java内存模型,讲之前,先看看 CPU缓存模型:

CPU缓存模型:

CPU Cache:

我们知道,CPU是负责执行指令的;自身的频率和指令执行的速度非常快,比内存还要快好几个级别。 如果,每次读写都要和内存交互,性能就会很低。 因此,CPU也有自己的缓存用于解决 CPU处理速度 与 内存读写速度不匹配的矛盾;就像内存缓存的是硬盘数据,用于解决硬盘访问速度过慢的问题。

如图,现在的电脑都有多个CPU,每个CPU都有多个核。 每个核里面,都有自己的缓存L1,L2。 多个核共享L3, 多个CPU共享主内存。 L1,L2,L3就是CPU自己的缓存(整体可以都看做CPU Cache),他们的工作方式是,将内存的数据复制到CPU Cache中使用,计算完成后将结果写入内存中。 

但是,如果多个线程同时从主内存当中,读取了一个副本,都进行各自的计算,就可能造成结果不一致的问题。 因此,它们需要遵循一定的规范协议来保证数据同步,即 缓存一致性协议。 这些规范就是操作系统通过内存模型定义的,无论windows、linux,他们都有自己的内存模型。

寄存器:

寄存器是CPU内部的最快和最小的存储器,比CPU Cache更快,直接和CPU核心交互。 它有很多buffer组成,如store buffer,load buffer等。  它和CPU Cache 都是存储器,但CPU Cache并不是由寄存器组成的

内存可见性问题:

有了缓存一致性协议的保障,对于CPU Cache(L1, L2, L3)和主内存,数据是同步的。   但是呢,在寄存器和这些缓存之间,是异步的。  比如向内存中写一个变量,会先保存在store buffer里面, 稍后异步的写入L1中,同时同步的写入主内存中,最终可能造成数据不一致。  因此,从宏观层面来看,可以看做: 每个cpu都有自己的缓存,缓存和主内存不同步,造成结果不正确。

对应到java中,就是JVM抽象的内存模型了: JMM(Java Memory Model)

指令重排序 与 内存可见性问题 的关系: 

程序执行时,为了提升效率,编译器和处理器都会对代码的指令重新排序,不一定按照你写的代码顺序执行。 一般分为:  编译器对于指令的重排、指令并行重排、内存系统对指令的重排。   这些重排序,在单线程下结果不会有变化,但是在多线程下,可能会出问题。 比如上面说的,store buffer延迟写入的内存可见性问题,就是重排序的第三种。 因此,我们需要 内存屏障 来保证。

内存屏障: 

一种计算机硬件或软件机制,用于控制处理器和内存之间的数据同步和可见性。 它可以禁止编译器重排序和 CPU 重排序。

编译器的内存屏障,只是为了告诉编译器不要对指令进行重排序。当编译完成之后,这种内存屏障 就消失了,CPU并不会感知到编译器中内存屏障的存在。

CPU的内存屏障,是CPU提供的指令,可以由开发者显示调用。

内存屏障通常包含以下几种:

  1. LoadLoad:禁止读和读的重排序,保证两次读按顺序执行。
  2. StoreStore:禁止写和写的重排序,保证两次写按顺序执行。
  3. LoadStore:禁止读和写的重排序,保证先读后写。
  4. StoreLoad:禁止写和读的重排序,保证先写后读。

JavaUnsafe类中提供了三个:

  1. loadFence=LoadLoad+LoadStore
  2. storeFence=StoreStore+LoadStore
  3. fullFence=loadFence+storeFence+StoreLoad

JMM: 

JMM模型,在上面简单看过,它抽象了线程和主内存的关系,也就是每个线程有自己的缓存副本,这些线程共享主内存。为了保证这种模型下不出问题,JMM描述了一组规范,定义了程序中对各个变量的访问方式。

比如:使用volatile修饰的变量

  • 写操作前,插入StoreStore,保证多次写按顺序操作; 
  • 写操作后,插入StoreLoad,保证写完后再读;
  • 读操作前,插入loadFence,保证读写顺序;

总之,volatile修饰的变量,可以让多个线程之间拿到内存最新的值,保证读写不乱序。final也可以保证数据不被更改,还可以使用像synchronized、Lock等同步机制,也可以保证多个线程之间按串行。  他们都可以禁止重排序,保证最终结果。作为开发人员,不需要关注底层实现,正确使用即可。

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

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

相关文章

阵列信号处理_对比常规波束形成法(CBF)和Capon算法

空间谱估计 利用电磁波信号来获取目标或信源相对天线阵列的角度信息的方式,也称测向、波达方向估计(DOA)。主要应用于雷达、通信、电子对抗和侦察等领域。 发展 常规波束形成(CBF)。本质是时域傅里叶变换在空域直接…

双十一期间如何抢占流量,打造品牌爆款产品

进入10月末,也就进入了电商行业的大促流量红利期。如何提前规划大促期间,店铺流量扩张的计划,提前抢占流量,是每一个品牌方都需要考虑的问题。今天为大家分享下双十一期间如何抢占流量,打造品牌爆款产品! 一…

复制粘贴,不如Ctrl+D~预制体和变体

复制并粘贴:Ctrl D 问题 当你Ctrl D复制粘贴出几个新物体时,你这时又去修改新物体,导致所有物体不一样该怎么办? 预制体的使用 使用预设体的好处:修改预设体的文件数值,会影响其对应的物体&#xff1…

Python下载与安装进阶

一.python下载,安装与常见问题 玩转python下载与安装 下载流程:在百度搜索“python”——》打开python官网 ——》选择python版本——>另存为python安装程序手动修改环境变量修改安装目录 1. 玩转python下载与安装 流程: 识别电脑的…

“探寻服务器的无限潜能:从创意项目到在线社区,你会做什么?”

文章目录 每日一句正能量前言什么是服务器?服务器能做什么?服务器怎么用?部署创意项目,还是在线社区亦或做其他的?后记 每日一句正能量 未知的下一秒,千万不要轻言放弃。 前言 在数字化时代,服…

vs2019 libtiff安装及应用

vs2019 libtiff安装及应用 1.下载libtiff2.解压并编译3.查看编译结果4.demo测试4.1 配置项目4.2 编辑demo文件 5. 遇到的bug参考文献 1.下载libtiff 从libtiff 下载地址下载一个版本,这里选择4.0.8. 2.解压并编译 解压至目的地址: E:\cpp_lib\tiff-4.…

【软考-中级】系统集成项目管理工程师 【18 风险管理】

持续更新。。。。。。。。。。。。。。。 【第十八章】风险管理 (选择3分,偶尔案例18 分 18.1 风险概述18.1.1 风险的定义18.1.2 风险的分类18.1.3 风险的性质 18.2 项目风险管理18.3 规划风险管理18.3.1 规划风险管理的输入18.3.2 规划风险管理的工具与技术18.3.3 …

【面试经典150 | 区间】合并区间

文章目录 Tag题目来源题目解读解题思路方法一:一次遍历 其他语言python3 写在最后 Tag 【排序】【一次遍历】【数组】 题目来源 56. 合并区间 题目解读 题目意思非常明确,合并有重叠的区间。 解题思路 数据量为 1 0 4 10^4 104,基本上需…

分布式系统部署Redis

文章目录 一、单点问题二、主从模式概念配置主从结构查看主从节点断开从属关系拓扑结构主从复制原理replication复制offset偏移量 全量复制和部分复制全量复制部分复制 实时复制redis主节点无法重启 三、主从哨兵模式哨兵概念监控程序人工恢复自动恢复为什么是哨兵集合使用dock…

Vue 网络处理 - axios 异步请求的使用,请求响应拦截器

目录 一、axiox 1.1、axios 简介 1.2、axios 基本使用 1.2.1、下载核心 js 文件. 1.2.2、发送 GET 异步请求 1.2.3、发送 POST 异步请求 1.2.4、发送 GET、POST 请求最佳实践 1.3、请求响应拦截器 1.3.1、拦截器解释 1.3.2、请求拦截器的使用 1.3.3、响应拦截器的使用…

为网站配置SSL

HTTPS (全称:Hyper Text Transfer Protocol over SecureSocket Layer),是以安全为目标的 HTTP 通道,在HTTP的基础上通过传输加密和身份认证保证了传输过程的安全性。HTTPS 在HTTP 的基础下加入SSL 层,HTTPS…

城市生命线专题周丨宏电燃气管线智慧化运营解决方案,助力燃气安全运营高质量发展

方案背景 随着我国城市发展建设速度的加快和国家能源结构的调整,天燃气走进了千家万户,燃气门站和城市燃气管网规模越来越庞大。此外,近年燃气泄漏导致的大型爆炸事件频发,给人民的生命安全和财产安全带来灾难性伤害。 行业痛点 …

LeetCode1389

LeetCode1389 思路:先将元素存放在集合中,集合中的add(index,value)方法可以在指定的位置插入元素。 再创建新的数组,将集合中的元素存入数组,直接用数组的话元素移动不好操作。 public class D…

基于 Triple 实现 Web 移动端后端全面打通

*作者:陈有为,陌陌研发工程师、Apache Dubbo PMC RPC 协议开发微服务 在我们正常开发微服务的时候,传统 RPC 服务可能在最底层。上层可能是浏览器、移动端、外界的服务器、自己的测试、curl 等等。我们可能会通过 Tomcat 这种外部服务器去组…

Win10 搭建FTP服务器

1. FTP 服务器用途 局域网中,资料共享,如果想实现外网访问可以设置路由端口映射(不建议外网一旦打开风险增大) 2. FTP服务器可以设置用户权限有什么? 用户只能读取 用户只能写入 用户读取写入 使用场景&#xff…

让GPT回复图片的咒语

咒语如下&#xff1a; 帮我画一张图关于XXXXX,用3/8Markdown 写&#xff0c;不要有反斜钱,不要用代码块。使用Unsplash APl(https://source.unsplash.com/1280x720/?<PUT YOUR QUERY HERE >) Over! ​​​​​​​

面向红队的自动化引擎工具

gogo 介绍 面向红队的、高度可控的可拓展的自动化引擎。特征如下&#xff1a; 自由的端口配置 支持主动/主动指纹识别 关键信息提取&#xff0c;如标题、证书以及自定义提取信息的正则 支持nuclei poc&#xff0c;poc目录&#xff1a;https://chainreactors.github.io/wiki/…

centos7安装erlang23.3.4.11及rabbitmq3.9.16版本

rpm包有系统版本要求&#xff0c;el是Red Hat Enterprise Linux(EL)的缩写。 EL7是Red Hat 7.x&#xff0c;Centos 7.x EL8是Red Hat 8.x, Centos 8.x 所以我们在安装erlang及rabbitmq时需要选择与自己的服务器相对应的rpm包 # rabbitmq的rpm安装包 https://github.com/rabbi…

小程序技术加速信创操作系统国产化替换

随着信息技术的不断发展&#xff0c;信息技术应用创新&#xff08;简称“信创”&#xff09;已经成为了当今企业数字化转型的重要趋势之一。信创是指在信息技术领域&#xff0c;以自主可控的国产软硬件产品和服务为核心&#xff0c;构建起一套完整的信息技术生态体系&#xff0…

【仪器仪表专题】案例:测试充电芯片保护时间测试10小时后电子负载自动下线是为什么?

测试充电芯片保护时间有两种办法,一种是使用真实的电池让充电芯片一直充电(可以通过降充电电流、修改时间参数或是并电池增加容量的方式)。另一种是使用电子负载的CV模式模拟电池(需要增加一个芯片NTC电阻来避免充电芯片发生NTC错误)。 为了最完整的还原这个过程,我采取…