线程的四种操作

2024-09-09 04:52
文章标签 线程 操作 四种

本文主要是介绍线程的四种操作，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

  所属专栏：Java学习     

在这里插入图片描述

 

1. 线程的开启

start和run的区别：

run：描述了线程要执行的任务，也可以称为线程的入口

start：调用系统函数，真正的在系统内核中创建线程（创建PCB，加入到链表中），此处的start会根据不同的系统，分别调用不同的api，创建好之后的线程，再单独去执行run（所以说，start的本质是调用系统api，系统的api会在内核中创建线程）

start执行的速度是比较快的，一旦 start 执行完毕，新线程就会开始执行，调用start的线程，main线程也会继续执行

在Java中，一个Thread对象只能对应到一个系统中的线程，在start中就会根据线程的状态来判断，如果Thread对象没有start，此时的状态就是一个new状态，可以顺利调用start，如果已经调用过start，就会进入到其他状态，只要不是new状态，都会抛出异常

2. 线程的终止

当线程B正在运行时，如果发生了特殊情况需要终止掉线程，有两种实现方式：

  1. 通过共享的标记来进行沟通
  2. 调用interrupt()方法来通知

先来看使用自定义的isQuit作为标志位的例子：

public class ThreadDemo4 {private static boolean isQuit = false;public static void main(String[] args) throws InterruptedException {Thread thread = new Thread(){@Overridepublic void run() {while (!isQuit){System.out.println("thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}System.out.println("thread线程终止了");}};thread.start();Thread.sleep(1000);System.out.println("main线程尝试终止thread线程...");isQuit = true;}
}

这时就有一个问题需要注意：

如果isQuit不用static修饰，改为main方法里的局部变量可行不可行？ans:肯定是不可行的

这就涉及到了lambda表达式变量捕获的问题了

变量捕获是lambda表达式/匿名内部类中的一个语法规则：isQuit和lambda表达式定义在一个作用域中，此时lambda内部是可以访问到外部（和lambda同一个作用域）中的变量的，Java中的变量捕获是有一个特殊要求的，要求捕获的变量必须是final或事实final（虽然不是final修饰，但是后面没有更改）

就如上面的代码中，isQuit后面是被修改了的，所以就违反了语法规则

刚开始的形式为什么可以：写在外面就是外部类的成员变量，内部类本来就是可以访问外部类的

再来看interrupted的例子：

Thread类里面有一个boolean类型的成员变量interrupted，初始状态为false，一旦外面有线程调用interrupt方法，就会设置标志位为true

public class ThreadDemo5 {public static void main(String[] args) throws InterruptedException {Thread thread = new Thread(()->{Thread currentThread = Thread.currentThread();while (!currentThread.isInterrupted()){System.out.println("thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}});thread.start();Thread.sleep(1000);//主线程中控制thread被终止，设置标志位thread.interrupt();}
}

看起来是和自定义的标志位一样的，但是运行之后就会发现出现了异常：

由于在循环中判断和打印的操作太快了，整个循环的时间都是花在sleep方法里的，当main中调用interrupt时，大概率线程thread是在sleep中的，此时Interrupt就不仅能设置标志位，还可以唤醒thread线程，就会抛出InterruptedException异常，catch中捕获到异常也是做了抛出处理，就交给了JVM，程序就异常终止，那么把处理异常的方式更改一下试试：

这时就会发现while循环中的代码一直在执行

这里的原因是当sleep等阻塞函数被唤醒之后，就会清空刚刚设置的标志位，这时interrupted就一直是初始状态，也就导致了死循环，如果需要结束循环，可以把刚刚的异常处理直接改为break。

Java中终止线程的方式：A线程希望B线程能够终止，B线程收到这样的请求之后就可以自行决定是否是立即终止，稍后终止还是直接无视

  1. 如果B线程想要无视A，catch中就什么也不做，B线程就继续执行（sleep清除标志位）
  2. 如果B线程想要立即结束，就在catch中直接break或return
  3. 如果B线程想要稍后再终止，就可以在catch中添加其他的逻辑（释放资源，清理数据，提交结果...），这些完成之后再break/return.

3. 线程的等待

在之前提到过，操作系统针对多个线程的执行是一个“随机执行，抢占式调度”的过程，哪条线程先执行和先结束是不确定的，不过可以通过使用线程等待来决定哪条线程先结束，也就是让最后结束的线程等待先结束的线程，此时后结束的线程就进入了阻塞状态

例如在a线程中调用b.join()，就是让a线程等待b线程先结束，然后a再继续执行

public class ThreadDemo6 {public static void main(String[] args) {Thread thread1 = new Thread(() -> {for (int i = 0; i < 3; i++) {System.out.println("thread1");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}System.out.println("thread1结束了");});thread1.start();System.out.println("main线程开始等待");try {thread1.join();} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("main线程结束等待");}
}

上面的代码是thread1线程先执行，然后main线程开始等待，进入阻塞状态，如果说修改为先让thread1线程结束，main线程再开始等待会如何呢？

此时join并没有发生阻塞，join方法就是确保被等待的线程能够先结束，如果已经结束了，就没有等待的必要了

此外，任何线程都可以等待别的线程，而且可以等待多个线程，或者是多个线程之间互相等待

public class ThreadDemo7 {public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(()->{for(int i = 0;i < 3;i++){System.out.println("线程t1执行...");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}System.out.println("线程t1结束");});Thread t2 = new Thread(()->{for(int i = 0;i < 3;i++){System.out.println("线程t2执行...");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}System.out.println("线程t2结束");});t1.start();t2.start();System.out.println("main线程开始等待...");t1.join();t2.join();System.out.println("main线程结束等待");}
}

这就是main线程同时等待两个线程的例子，关于两个join的顺序其实没有区别，最终都是等待了4s

在main等待t1和t2同时，t2也可以等待t1：

这样就把原来t1和t2并发执行修改为了t1先执行

main线程也可以被其他线程等待，不过写法不同的是，需要先获取main线程的引用

public class ThreadDemo8 {public static void main(String[] args) throws InterruptedException {Thread mainThread = Thread.currentThread();Thread thread = new Thread(()->{System.out.println("thread等待main线程");try {mainThread.join();} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("结束等待");});thread.start();Thread.sleep(1000);System.out.println("main线程结束");}
}

在上面使用的join方法中，由于是没有传入参数的，就表示被等待的线程只要没有执行完，就会一直等待，这种方式肯定是不好的，如果被等待的线程出现问题了，就会使这个等待操作一直进行，所以就有了传参的版本，但上面列举的第三个高精度的一般也用不到

4. 线程的休眠

之前一直用的Thread.sleep()这个操作就是让调用的线程阻塞等待一定时间的，线程执行sleep之后，就会使这个线程不参与CPU的调度，把CPU的资源让出来，给其他线程使用，在开发时，如果发现某个线程的CPU占用率过高，就可以通过sleep来改善，虽然说线程的优先级也可以影响，但比较有限

在这里插入图片描述

这篇关于线程的四种操作的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


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

相关文章

动手学深度学习【数据操作+数据预处理】

动手学深度学习【数据操作+数据预处理】

import osos.makedirs(os.path.join('.', 'data'), exist_ok=True)data_file = os.path.join('.', 'data', 'house_tiny.csv')with open(data_file, 'w') as f:f.write('NumRooms,Alley,Price\n') # 列名f.write('NA
阅读更多...
Java IO 操作——个人理解

Java IO 操作——个人理解

之前一直Java的IO操作一知半解。今天看到一个便文章觉得很有道理（ 原文章），记录一下。 首先，理解Java的IO操作到底操作的什么内容，过程又是怎么样子。          数据来源的操作： 来源有文件，网络数据。使用File类和Sockets等。这里操作的是数据本身，1,0结构。    File file = new File("path");   字
阅读更多...
MySQL——表操作

MySQL——表操作

目录 一、创建表 二、查看表 2.1 查看表中某成员的数据 2.2 查看整个表中的表成员 2.3 查看创建表时的句柄 三、修改表 alter 3.1 重命名 rename 3.2 新增一列 add 3.3 更改列属性 modify 3.4 更改列名称 change 3.5 删除某列 上一篇博客介绍了库的操作，接下来来看一下表的相关操作。 一、创建表 create
阅读更多...
java线程深度解析（六）——线程池技术

java线程深度解析（六）——线程池技术

http://blog.csdn.net/Daybreak1209/article/details/51382604 一种最为简单的线程创建和回收的方法： [html]  view plain copy new Thread(new Runnable(){                @Override               public voi
阅读更多...
java线程深度解析（五）——并发模型（生产者-消费者）

java线程深度解析（五）——并发模型（生产者-消费者）

http://blog.csdn.net/Daybreak1209/article/details/51378055 三、生产者-消费者模式     在经典的多线程模式中，生产者-消费者为多线程间协作提供了良好的解决方案。基本原理是两类线程，即若干个生产者和若干个消费者，生产者负责提交用户请求任务（到内存缓冲区），消费者线程负责处理任务（从内存缓冲区中取任务进行处理），两类线程之
阅读更多...
java线程深度解析（四）——并发模型（Master-Worker）

java线程深度解析（四）——并发模型（Master-Worker）

http://blog.csdn.net/daybreak1209/article/details/51372929 二、Master-worker ——分而治之      Master-worker常用的并行模式之一，核心思想是由两个进程协作工作，master负责接收和分配任务，worker负责处理任务，并把处理结果返回给Master进程，由Master进行汇总，返回给客
阅读更多...
java线程深度解析（二）——线程互斥技术与线程间通信

java线程深度解析（二）——线程互斥技术与线程间通信

http://blog.csdn.net/daybreak1209/article/details/51307679      在java多线程——线程同步问题中，对于多线程下程序启动时出现的线程安全问题的背景和初步解决方案已经有了详细的介绍。本文将再度深入解析对线程代码块和方法的同步控制和多线程间通信的实例。 一、再现多线程下安全问题 先看开启两条线程，分别按序打印字符串的
阅读更多...
java线程深度解析（一）——java new 接口？匿名内部类给你答案

java线程深度解析（一）——java new 接口？匿名内部类给你答案

http://blog.csdn.net/daybreak1209/article/details/51305477 一、内部类 1、内部类初识 一般，一个类里主要包含类的方法和属性，但在Java中还提出在类中继续定义类（内部类）的概念。 内部类的定义：类的内部定义类 先来看一个实例 [html]  view plain copy pu
阅读更多...
封装MySQL操作时Where条件语句的组织

封装MySQL操作时Where条件语句的组织

在对数据库进行封装的过程中，条件语句应该是相对难以处理的，毕竟条件语句太过于多样性。 条件语句大致分为以下几种： 1、单一条件，比如：where id = 1; 2、多个条件，相互间关系统一。比如：where id > 10 and age > 20 and score < 60; 3、多个条件，相互间关系不统一。比如：where (id > 10 OR age > 20) AND sco
阅读更多...
PHP7扩展开发之流操作

PHP7扩展开发之流操作

前言 啥是流操作？简单来讲就是对一些文件，网络的IO操作。PHP已经把这些IO操作，封装成流操作。这节，我们将使用PHP扩展实现一个目录遍历的功能。PHP示例代码如下： <?phpfunction list_dir($dir) {if (is_dir($dir) === false) {return;} $dh = opendir($dir);if ($dh == false) {ret
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2