线程终止,线程的相关方法,线程状态图以及线程的同步机制。

2023-12-17 06:52

本文主要是介绍线程终止,线程的相关方法,线程状态图以及线程的同步机制。,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

首先我们知道了什么是线程,以及线程的实现方法,接下来我们来了解一下继承Thread类和Runnable接口的区别,其实本质上是没有区别的,因为Thread也实现了Runnable的接口,唯一区别就是使用Runnable接口,可以实现多个线程共享一个资源的情况,而且不会受到单继承的限制,这里我们建议使用Runnable接口。

我们再来聊一下线程终止的操作,线程终止顾名思义就是想让进程停止运行,我们可以通过设置变量的方法来使线程退出,即通知方式,这里我们用一个实例来进行演示:

public class ift {public static void main(String[] args) {Preson2 preson2 = new Preson2(true);Thread thread = new Thread(preson2);thread.start();for (int i = 0; i < 10; i++){try {Thread.sleep(500);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("hi~");if (i == 5){preson2.setf(false);}}}
}class Preson2 implements Runnable{public Boolean b;public Preson2(Boolean b) {this.b = b;}@Overridepublic void run() {while(b){try {Thread.sleep(500);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("hello~");}}public void setf(Boolean b){this.b = b;}
}

 

这里我们发现hello只被执行了五次,是因为我们在主线程中设定了终止信息,才实现了该功能;

线程还有一系列的相关方法:

这是线程的常用方法,我们就不一一列举了。

这里提示一下:interrupt方法并不是中断一个线程的运行,而是让正在休眠的线程提前中断休眠,让它重新运作。

这里有俩个非常常用的方法一个是yield:线程的礼让,一个是join:线程插队,线程的礼让:让出cpu,给其他线程先运行,但是会根据cpu的运行状态来确定,如果cpu的资源很丰富则不会礼让成功,所以线程礼让是不确定的,它不一定会成功,线程插队:线程插队跟线程礼让不同,它比较霸道,一旦插队成功是必须先执行完该线程,才会将cpu让出来给其他线程使用。

join方法:

public class ift {public static void main(String[] args) {Thread t3 = new Thread(new T3());//创建子线程for (int i = 1; i <= 10; i++) {System.out.println("hi " + i);if(i == 5) {//说明主线程输出了 5 次 hit3.start();//启动子线程 输出 hello... t3.join();//立即将 t3 子线程,插入到 main 线程,让 t3 先执行try {t3.join();} catch (InterruptedException e) {throw new RuntimeException(e);}}try {Thread.sleep(1000);//输出一次 hi, 让 main 线程也休眠 1s} catch (InterruptedException e) {throw new RuntimeException(e);}}}}class T3 implements Runnable{private int count = 0;@Overridepublic void run() {while (true) {System.out.println("hello " + (++count));try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}if (count == 10) {break;}}}
}

 

yield方法:

public class ift {public static void main(String[] args) {Thread t3 = new Thread(new T3());//创建子线程for (int i = 1; i <= 10; i++) {System.out.println("hi " + i);if(i == 5) {//说明主线程输出了 5 次 hit3.start();//启动子线程 输出 hello... t3.join();//立即将 t3 子线程,插入到 main 线程,让 t3 先执行t3.yield();}try {Thread.sleep(1000);//输出一次 hi, 让 main 线程也休眠 1s} catch (InterruptedException e) {throw new RuntimeException(e);}}}}class T3 implements Runnable{private int count = 0;@Overridepublic void run() {while (true) {System.out.println("hello " + (++count));try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}if (count == 10) {break;}}}
}

 

这里我们发现并没有礼让成功而是交替输出。

接下来我们看一下线程的状态图:
  

Runnable状态在jvm机中又被分为ready和running两个状态。

我们可以通过getState()这个方法来查询线程的当前状态,我们写个实例来看一下:

public class ift {public static void main(String[] args) throws InterruptedException {T t = new T();System.out.println(t.getName() + " 状态 " + t.getState());//NEWt.start();while (Thread.State.TERMINATED != t.getState()) {System.out.println(t.getName() + " 状态 " + t.getState());//TIMED_WAITING,原因线程每运行一次就休眠一秒钟Thread.sleep(500);}System.out.println(t.getName() + " 状态 " + t.getState());//TERMINATED}
}
class T extends Thread {@Overridepublic void run() {while (true) {for (int i = 0; i < 10; i++) {System.out.println("hi " + i + getState());//RUNNABLEtry {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}break;}}
}
while (Thread.State.TERMINATED != t.getState()) {System.out.println(t.getName() + " 状态 " + t.getState());//TIMED_WAITING,原因线程每运行一次就休眠一秒钟Thread.sleep(500);
}

该循环内大家肯定有疑问,为什么一直都是TIMED_WAITING状态,为什么刚启动后的RUNNABLE状态打印不了,那是因为运行的过程很快可能就几毫秒,所以根本捕捉不到该状态,但是休眠的时间很长所以打印的都是休眠的状态,运行状态可以在它运行的时候一块打印出来,就像我写的一样,给大家看一下结果:

当我们休眠状态足够短的时候我们发现状态就会发生变化:

public class ift {public static void main(String[] args) throws InterruptedException {T t = new T();System.out.println(t.getName() + " 状态 " + t.getState());//NEWt.start();while (Thread.State.TERMINATED != t.getState()) {System.out.println(t.getName() + " 状态 " + t.getState());//TIMED_WAITING,原因线程每运行一次就休眠一秒钟Thread.sleep(2);}System.out.println(t.getName() + " 状态 " + t.getState());//TERMINATED}
}
class T extends Thread {@Overridepublic void run() {while (true) {for (int i = 0; i < 10; i++) {System.out.println("hi " + i + getState());//RUNNABLEtry {Thread.sleep(1);} catch (InterruptedException e) {e.printStackTrace();}}break;}}
}

 

接下来我们来学习一下线程的同步机制:什么是线程的同步机制我们先来看一个实例来引出线程同步机制的作用:

public class Tick {public static void main(String[] args) {sellTcik sellTcik = new sellTcik();new Thread(sellTcik).start();new Thread(sellTcik).start();new Thread(sellTcik).start();}}class sellTcik implements Runnable{@SuppressWarnings({"all"})public int tick = 100;Object object = new Object();private Boolean loop = true;public void run(){while(loop){m();}}public void m(){if (tick == 0) {System.out.println("售票结束");loop = false;return;}System.out.println("线程" + Thread.currentThread().getName() + "     " + (--tick));try {Thread.sleep(10);} catch (InterruptedException e) {throw new RuntimeException(e);}}
}

当我们运行代码的时候我们就会发现一些问题:

它的票数可能出现负数的情况,这是为什么呢,这是因为它是三个线程一块进入进行操作的,假如票还有两张,三个线程一块进去检测票数确实大于0,所以会直接拿去卖,买了三张,所以出现 了超票的情况,那我们怎么来解决这样的情况呢,这里就要用到我们的线程同步机制了,它的实现方法是synchronized(),括号内可以添加一个对象,相当于一把锁,只有拿到锁的线程才能进入我们的方法中,但是听起来效率会大大降低,线程的深入学习,以后会进行讨论,我们先来了解目前学习的方法,而且这个锁,有个特点,它对于线程而言必须指向的同一个对象,如果是不同对象,那该锁则是无效的,这里我们使用接口类中的Object类型的对象,因为实现Runnable接口只需要创建一个对象即可,如果我们用的是继承Thread的方法时,我们需要创建多个对象,这是我们可以将Object类型设置为静态属性这里可以给多线程共享相同的资源。所以object对象肯定是相同对象(synchronized()被该方法框起来的代码越少越好,可以提升效率)。

public class Tick {public static void main(String[] args) {sellTcik sellTcik = new sellTcik();new Thread(sellTcik).start();new Thread(sellTcik).start();new Thread(sellTcik).start();}}class sellTcik implements Runnable{@SuppressWarnings({"all"})public int tick = 100;Object object = new Object();private Boolean loop = true;public void run(){while(loop){m();}}public void m(){synchronized (object) {if (tick == 0) {System.out.println("售票结束");loop = false;return;}System.out.println("线程" + Thread.currentThread().getName() + "     " + (--tick));try {Thread.sleep(10);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}

如果设置同步方法

public synchronized static void m1() {
}
它默认的锁就是该类的类名.class

这里我们发现超票的问题得到了很好的解决。(同步机制的互斥锁大多设置为自己的类即类名.class),该锁是必然有效的,因为类只能有一个,可以根据自己的喜好,自行添加锁。

互斥锁:

互斥锁的特征就像上述所说,只允许一个线程拿到锁,等到该线程运行完才能让其他线程进入,而且互斥锁,必须指向的同一对象,如果不同对象进入拿到的锁不同,则无法做到限制的作用,则该锁无效。

线程死锁:

我们直接模拟死锁给大家一个直观的感受:

public class Tick {public static void main(String[] args) {//模拟死锁现象DeadLockDemo A = new DeadLockDemo(true);A.setName("A 线程");DeadLockDemo B = new DeadLockDemo(false);B.setName("B 线程");A.start();B.start();}}class DeadLockDemo extends Thread {static Object o1 = new Object();// 保证多线程,共享一个对象,这里使用 staticstatic Object o2 = new Object();boolean flag;public DeadLockDemo(boolean flag) {//构造器this.flag = flag;}@Overridepublic void run() {//1. 如果 flag 为 T, 线程 A 就会先得到/持有 o1 对象锁, 然后尝试去获取 o2 对象锁//2. 如果线程 A 得不到 o2 对象锁,就会 Blocked//3. 如果 flag 为 F, 线程 B 就会先得到/持有 o2 对象锁, 然后尝试去获取 o1 对象锁//4. 如果线程 B 得不到 o1 对象锁,就会 Blockedif (flag) {synchronized (o1) {//对象互斥锁, 下面就是同步代码System.out.println(Thread.currentThread().getName() + " 进入 1");synchronized (o2) { // 这里获得 li 对象的监视权System.out.println(Thread.currentThread().getName() + " 进入 2");}}} else {synchronized (o2) {System.out.println(Thread.currentThread().getName() + " 进入 3");synchronized (o1) { // 这里获得 li 对象的监视权System.out.println(Thread.currentThread().getName() + " 进入 4");}}}}
}

 

我们发现A,B两线程都处于了Blocked状态,这就是死锁,互相拿着对方需要的锁,无法继续往下运行。

 

 

 

这篇关于线程终止,线程的相关方法,线程状态图以及线程的同步机制。的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/503483

相关文章

Maven中引入 springboot 相关依赖的方式(最新推荐)

《Maven中引入springboot相关依赖的方式(最新推荐)》:本文主要介绍Maven中引入springboot相关依赖的方式(最新推荐),本文给大家介绍的非常详细,对大家的学习或工作具有... 目录Maven中引入 springboot 相关依赖的方式1. 不使用版本管理(不推荐)2、使用版本管理(推

Java 中的 @SneakyThrows 注解使用方法(简化异常处理的利与弊)

《Java中的@SneakyThrows注解使用方法(简化异常处理的利与弊)》为了简化异常处理,Lombok提供了一个强大的注解@SneakyThrows,本文将详细介绍@SneakyThro... 目录1. @SneakyThrows 简介 1.1 什么是 Lombok?2. @SneakyThrows

判断PyTorch是GPU版还是CPU版的方法小结

《判断PyTorch是GPU版还是CPU版的方法小结》PyTorch作为当前最流行的深度学习框架之一,支持在CPU和GPU(NVIDIACUDA)上运行,所以对于深度学习开发者来说,正确识别PyTor... 目录前言为什么需要区分GPU和CPU版本?性能差异硬件要求如何检查PyTorch版本?方法1:使用命

Qt实现网络数据解析的方法总结

《Qt实现网络数据解析的方法总结》在Qt中解析网络数据通常涉及接收原始字节流,并将其转换为有意义的应用层数据,这篇文章为大家介绍了详细步骤和示例,感兴趣的小伙伴可以了解下... 目录1. 网络数据接收2. 缓冲区管理(处理粘包/拆包)3. 常见数据格式解析3.1 jsON解析3.2 XML解析3.3 自定义

SpringMVC 通过ajax 前后端数据交互的实现方法

《SpringMVC通过ajax前后端数据交互的实现方法》:本文主要介绍SpringMVC通过ajax前后端数据交互的实现方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价... 在前端的开发过程中,经常在html页面通过AJAX进行前后端数据的交互,SpringMVC的controll

Java中的工具类命名方法

《Java中的工具类命名方法》:本文主要介绍Java中的工具类究竟如何命名,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录Java中的工具类究竟如何命名?先来几个例子几种命名方式的比较到底如何命名 ?总结Java中的工具类究竟如何命名?先来几个例子JD

Spring Security自定义身份认证的实现方法

《SpringSecurity自定义身份认证的实现方法》:本文主要介绍SpringSecurity自定义身份认证的实现方法,下面对SpringSecurity的这三种自定义身份认证进行详细讲解,... 目录1.内存身份认证(1)创建配置类(2)验证内存身份认证2.JDBC身份认证(1)数据准备 (2)配置依

python获取网页表格的多种方法汇总

《python获取网页表格的多种方法汇总》我们在网页上看到很多的表格,如果要获取里面的数据或者转化成其他格式,就需要将表格获取下来并进行整理,在Python中,获取网页表格的方法有多种,下面就跟随小编... 目录1. 使用Pandas的read_html2. 使用BeautifulSoup和pandas3.

Spring 中的循环引用问题解决方法

《Spring中的循环引用问题解决方法》:本文主要介绍Spring中的循环引用问题解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录什么是循环引用?循环依赖三级缓存解决循环依赖二级缓存三级缓存本章来聊聊Spring 中的循环引用问题该如何解决。这里聊

Java学习手册之Filter和Listener使用方法

《Java学习手册之Filter和Listener使用方法》:本文主要介绍Java学习手册之Filter和Listener使用方法的相关资料,Filter是一种拦截器,可以在请求到达Servl... 目录一、Filter(过滤器)1. Filter 的工作原理2. Filter 的配置与使用二、Listen