3.系统学习JavaEE:多线程

news/2024/10/30 19:30:09/

作者:爱塔居

专栏:JavaEE

作者介绍:大三学生,希望跟大家一起进步

文章目录

目录

文章目录

上章节回顾

一、中断线程

1.1 给线程中设定一个结束标志位。

 1.2 interrupt()

1.3为什么sleep要清空标志位呢?

二、等待一个线程—join()

三、线程的状态

 四、多线程带来的风险-线程安全(重点)


上章节回顾

1.线程的概念

线程之间资源共享,开销小,效率高。

2.进程和线程的区别

进程包含线程。(盖棺定论)一个进程里面至少有一个线程。进程是操作系统资源分配的基本单位。线程是操作系统进行调度执行的基本单位。

3.java代码如何创建线程

1)继承Thread,重写run

2)实现Runnable,重写run

3)继承Thread,匿名内部类

4)实现Runnable,匿名内部类

5)lambda表达式(推荐使用)

4.Thread常见属性

start方法:真正从系统这里,创建一个线程,新的线程将会执行run方法。

run方法表示了线程的入口方法是啥。(线程启动起来,要执行哪些逻辑。不是让程序员调用,要交给系统去自动调用)

一、中断线程

中断一个线程

中断这里就是字面意思,就是让一个线程停下来。线程的终止,本质上说,办法只有一种,就是让该线程的入口方法执行完毕。

1.1 给线程中设定一个结束标志位。

把循环条件用一个变量来控制:

package threading;
public class ThreadDemo6 {public static  boolean isQuit=false;public static void main(String[] args) {Thread t=new Thread(()-> {while (!isQuit){System.out.println("hello t");try{Thread.sleep(1000);//休息1秒}catch (InterruptedException e){e.printStackTrace();}}System.out.println("t 线程终止");});t.start();//在主线程中,修改isQuittry {Thread.sleep(3000);//主线程休息三秒}catch (InterruptedException e){e.printStackTrace();}isQuit=true;//将isQuit值改成true}
}

 如果把isQuit从成员变量改成局部遍历main。该代码能否正常工作?

不能。因为变量捕获。

lambda表达式能否访问外面的局部变量?可以,变量捕获语法规则。java要求变量捕获,捕获的变量必须是final或者实际final(变量没有用final修饰,但是代码中没有做出修改)。

 1.2 interrupt()

package threading;
public class ThreadDemo7 {public static void main(String[] args) {Thread t=new Thread(()->{//currentThread是获取当前线程实例//此处currentThread得到的对象就是t//isInterrupted是t对象里自带的一个标志位while (!Thread.currentThread().isInterrupted()){System.out.println("hello t");try {Thread.sleep(1000);}catch (InterruptedException e){e.printStackTrace();//打印出当前异常位置的调用栈}}});t.start();try{Thread.sleep(3000);}catch (InterruptedException e){e.printStackTrace();}//把t内部的标志位设置成true//如果该进程阻塞中,就会把阻塞状态唤醒,通过抛出异常的方式,让sleep结束。t.interrupt();//只执行一次}
}

 注意:当sleep被唤醒的时候,sleep会自动地把isInterrupted标志位给清空(true->fasle)

调用interrupt,设置了中断标志位,sleep第一次执行,清空了标志位,变成false,并抛出异常。sleep第二次执行,没有这个中断的标志位了。主线程并非是循环反复设置,而是只执行一次。

如果设置interrupt的时候,恰好,sleep刚醒。着生活,执行到下一轮的循环的条件后,也就直接结束了。不过这种概率很低,毕竟sleep的时间已经占据了整个循环体的99.999999999%的时间了。

 多线程的代码执行顺序不是“从上到下”,而是每个线程独立执行的。

多线程的调式是比较麻烦的。因为调试运行的效果和实际运行的效果可能差异很大。比如你给t线程打断点了,此时main线程仍然正常执行。

针对多线程的调试,最主要的方法是打印日志。

package threading;
public class ThreadDemo7 {public static void main(String[] args) {Thread t=new Thread(()->{//currentThread是获取当前线程实例//此处currentThread得到的对象就是t//isInterrupted是t对象里自带的一个标志位while (!Thread.currentThread().isInterrupted()){System.out.println("hello t");try {Thread.sleep(1000);}catch (InterruptedException e){e.printStackTrace();//打印出当前异常位置的调用栈break;}}});t.start();try{Thread.sleep(3000);}catch (InterruptedException e){e.printStackTrace();}//把t内部的标志位设置成true//如果该进程阻塞中,就会把阻塞状态唤醒,通过抛出异常的方式,让sleep结束。t.interrupt();}
}

当我们加上break,这个代码就能正常结束了。

1.3为什么sleep要清空标志位呢?

清空标志位的目的是让线程本身能够对于线程何时结束,有一个更明确的控制。

当前的interrupt方法效果,并不是让线程立即结束,而是告诉他,你该结束了,至于他是否真的要结束,立即结束还是等会结束,都是代码来灵活控制的。

 比如,你在打游戏的时候,妈妈让你帮忙到楼下扔个垃圾。

这时候,你要选择放下手机,立马去丢垃圾,还是跟妈妈说等会再去,还是直接说,我要打游戏,不丢垃圾呢?

 很明显,我们会先试试跟妈妈商量,“妈,打完这把,我就去丢垃圾。马上就打完了。”如果妈妈不同意,我们就会放下手机,赶紧下楼丢垃圾。

如果,我们在上网课,认真学习的时候,妈妈进来说,你去楼下丢个垃圾。

我们坚决跟妈妈说:“不。我正忙着听课呢。”

interrupt只是建议,不是命令。

 为什么java不强制设定为“命令结束”的操作呢?只要调用interru就立即结束呢?

因为设定成这种,非常不友好。

我们在打游戏的时候,说去丢垃圾,还能理解。毕竟,打游戏是一种娱乐。可是,正在认真学习,你二话不说,让我立马去丢垃圾,就很不合理了。

线程t何时结束,一定是t自己最清楚。交给t自己决定,就比较好。

二、等待一个线程—join()

线程之间是并发执行的。操作系统对于线程的调度是无序的,无法判定两个线程谁先执行结束,谁后执行结束。

package threading;public class ThreadDemo8 {public static void main(String[] args) {Thread t=new Thread(()->{System.out.println("hello t");});t.start();System.out.println("hello main");}
}

我们先输出hello main 还是输出hello t是无法确定的。这个代码实际执行的时候,大概率先输出hello main。毕竟创建线程,是需要开销的。不过不排除特定情况。

我们是不喜欢不确定的,会出概率性的bug,很难受。有的时候,我们就要明确规定线程的结束顺序。

我们可以使用线程等待来实现。

package threading;public class ThreadDemo8 {public static void main(String[] args) throws InterruptedException{Thread t=new Thread(()->{System.out.println("hello t");});t.start();t.join();System.out.println("hello main");}
}

 t.join()是在main线程中,调用t.join。意思是让main线程等待t先结束,再往下执行。

如果是在t1线程中,调用t2.join,就是让t1线程等待t2先结束。

在t。join执行的时候,如果t线程还没有结束,main线程就会阻塞等待。阻塞就是代码走到这一行就停下了,当前线程暂时不参与cpu的调度执行。

如果只有两个线程,main等待t,如果t短时间不结束,那是不是就不算并发了?

main阻塞了,不参加cpu调度了,此时就只有t去执行,单个线程确实也谈不上并发。

 1.main线程调用t.join的时候,如果t还在运行,此时main线程阻塞,知道t执行完毕(t的run执行完了),main才从阻塞中解除,才继续执行。

2.main线程调用t.join的时候,如果t已经结束了,此时join不会阻塞,就会立即往下执行。

这两种情况都能保证t是先结束的。

join还有一个版本,可以填写一个参数,作为“超时时间”,等待的最大时间。

join的无参数版本,效果就是“死等”,不见不散。

join的有参数版本,则是执行最大超时时间,如果等待的时间到了上限,还没有等到,咱就不等了。

会不会有两个线程互相等待的情况

会有的。那种情况称为死锁,是bug。比如家钥匙锁车里了,车钥匙锁家里了。

三、线程的状态

操作系统里的线程,自身是有一个状态的。但是Java Thread是对系统线程的封装,把这里的状态又进一步地精细化了。

NEW 系统中地线程还没创建出来呢,只是有一个Thread对象。

package threading;public class ThreadDemo9 {public static void main(String[] args) {Thread t=new Thread(()->{System.out.println("hello t");});System.out.println(t.getState());t.start();}
}

输出结果:

TERMINATED 系统中的线程已经执行完了,Thread对象还在。

package threading;public class ThreadDemo9 {public static void main(String[] args)throws InterruptedException {Thread t=new Thread(()->{System.out.println("hello t");});System.out.println(t.getState());t.start();Thread.sleep(2000);System.out.println(t.getState());}
}

RUNNABLE 就绪状态 

1)正在CPU上运行。

2)准备好随时可以去CPU上执行。

package threading;public class ThreadDemo9 {public static void main(String[] args)throws InterruptedException {Thread t=new Thread(()->{while (true){// System.out.println("hello t");}});System.out.println(t.getState());t.start();Thread.sleep(2000);System.out.println(t.getState());}
}

 

 TIMED_WAITNG 指定时间等待.sleep方法。

package threading;public class ThreadDemo9 {public static void main(String[] args)throws InterruptedException {Thread t=new Thread(()->{while (true){try {Thread.sleep(1000);}catch (InterruptedException e){e.printStackTrace();}}});System.out.println(t.getState());t.start();Thread.sleep(2000);System.out.println(t.getState());}
}


 BLOCKED 表示等待锁出现的状态

WAITING 使用wait方法出现的状态

 

 一条主线,三个支线。理解线程状态,意义就是让我们能够更好地进行多线程代码的调试。

 四、多线程带来的风险-线程安全(重点)

本章的重点,难点,考点。‘某个代码,在多线程环境下执行,会出bug=》线程不安全

举例子:

创建两个线程,各执行5w次自增。正常情况,结果是10w。

package threading;
//线程不安全
class Counter{private int count=0;public void add(){count++;}public int get(){return count;}
}
public class ThreadDemo10 {public static void main(String[] args) throws InterruptedException{Counter counter=new Counter();//搞两个线程,两个线程分别对这个counter自增5w次Thread t1=new Thread(()->{for (int i = 0; i <50000 ; i++) {counter.add();}});t1.start();Thread t2=new Thread(()-> {for (int i = 0; i < 50000; i++) {counter.add();}});t2.start();t1.join();t2.join();System.out.println(counter.get());}
}

输出结果:

 

我们会发现,不仅不是10w次,而且每次结果不一样。 

 解释一下为啥会出现这种情况,和线程的调度随机性密切相关

count++操作,本质上是三个cpu指令的构成

1.load,把内存中的数据读取到cpu寄存器中

2.add,就是把寄存器中的值,进行+1运算

3.save,把寄存器中的值写回到内存中

 由于多线程调度顺序是不确定的。实际执行过程中,这俩线程的++操作实际的指令排序顺序有很多种可能~

可能是这个样子:

也有可能是这样:

 还有这种可能:

 还有这种可能:

 也有这种可能:

此处两个线程的指令的排序顺序有着很多种排列情况。

不同的排列顺序,结果是截然不同的。

试着分析一下:

t1和t2是两个线程,可能是运行在不同的cpu核心上,也可能是运行在同一个cpu核心上(但是是分时复用,并发)这两种情况最终结果一致。

 

 这个结果是正常的。

我们再试着分析这种情况:

 

 此时我们发现,两个线程自增两次,最后结果是1.其中一次自增的结果,被另一次覆盖了。

 由于当前这两个线程调度顺序是无序的,有多少次是“顺序执行”,有多少次是“交错执行”是不知道的。

所以出现bug之后,得到的结果一定是<=10w。

结果是一定>=5w吗?

完全有可能小于5w,只是概率会小一些。

 


http://www.ppmy.cn/news/32545.html

相关文章

【前端】深入浅出缓存原理

缓存的基本原理 对于前端来说&#xff0c;缓存主要分为浏览器缓存&#xff08;比如 localStorage、sessionStorage、cookie等等&#xff09;以及http缓存&#xff0c;也是本文主要讲述的。 当然叫法也不一样&#xff0c;比如客户端缓存大概包括浏览器缓存和http缓存 所谓htt…

C语言进阶-数据的存储【详解】

一、类型的基本归类 &#xff08;1&#xff09;整型家族 字符存储和表示的时候本质上使用的是 ASCII 值&#xff0c;ASCII 值是整数&#xff0c;字符类型也归类到整型家族char 是不是 signed char 取决于编译器 &#xff08;2&#xff09;浮点数家族 浮点数家族包括&#xff1…

【Redis】高可用架构之哨兵模式 - Sentinel

Redis 高可用架构之哨兵模式 - Sentinel1. 前言2. Redis Sentinel 哨兵集群搭建2.1 一主两从2.2 三个哨兵3. Redis Sentinel 原理剖析3.1 什么哨兵模式3.2 哨兵机制的主要任务3.2.1 监控&#xff08;1&#xff09;每1s发送一次 PING 命令&#xff08;2&#xff09;PING 命令的回…

即时通讯系列-N-客户端如何在推拉结合的模式下保证消息的可靠性展示

结论先行 原则&#xff1a; server拉取的消息一定是连续的原则&#xff1a; 端侧记录的消息的连续段有两个作用&#xff1a; 1. 记录消息的连续性&#xff0c; 即起始中间没有断层&#xff0c; 2. 消息连续&#xff0c; 同时意味着消息是最新的&#xff0c;消息不是过期的。同…

排序算法汇总(数组+链表)

冒泡排序算法核心&#xff1a;相邻节点两两交换&#xff0c;重复进行&#xff08;n-1&#xff09;轮。时间复杂度为空间复杂度为是否稳定&#xff1a;稳定1.1 数组排序图1 冒泡排序算法&#xff08;数组&#xff09;public class BubbleSortArray {public static void main(Str…

Android开发 View属性

1. View View的子类及子类的子类都有View的属性&#xff0c;都可以设置下述介绍的属性。 2.View宽高 View及其派生类的宽高共有三类值&#xff1a; match_parent&#xff1a;匹配父控件的宽高 wrap_content: 匹配内容的长度&#xff0c;例如TextView是包裹文字 fixed numb…

JavaScript的事件传播机制

你在学习和编写JavaScript时可能听说过事件冒泡&#xff08;event bubbling&#xff09;。它会发生在多个元素存在嵌套关系&#xff0c;并且这些元素都注册了同一事件(例如click)的监听器时。 但是事件冒泡只是事件机制的一部分。它经常与事件捕获(event capturing)和事件传播…

【微信小程序】-- 全局数据共享 - MobX(四十三)

&#x1f48c; 所属专栏&#xff1a;【微信小程序开发教程】 &#x1f600; 作  者&#xff1a;我是夜阑的狗&#x1f436; &#x1f680; 个人简介&#xff1a;一个正在努力学技术的CV工程师&#xff0c;专注基础和实战分享 &#xff0c;欢迎咨询&#xff01; &…