JavaSE-10笔记【多线程1(+2024新)】

文章目录

  • 1.进程与线程
  • 2.并发与并行
  • 3.线程的调度模型
  • 4.实现线程
    • 4.1 第一种方式:继承Thread
    • 4.2 第二种方式:实现Runnable接口
    • 4.3 t.start()和t.run()的本质区别?
    • 4.4 线程常用的三个方法
  • 5.线程的生命周期(把生命周期图背会)
    • 5.1 Thread.sleep()方法
      • 5.1.1 关于Thread.sleep()的面试题
    • 5.2 如何中断一个线程的睡眠
    • 5.3 如何强行终止一个线程
      • 5.3.1 已过时的方式
      • 5.3.2 推荐的方式
    • 5.4 守护线程
    • 5.5 定时器
    • 5.6 线程合并
    • 5.7 线程优先级
    • 5.8 线程让位

重点掌握:线程安全和线程通信。

1.进程与线程

  • 进程是指操作系统中的一段程序,它是一个正在执行中的程序实例,具有独立的内存空间和系统资源,如文件、网络端口等。在计算机程序执行时,先创建进程,再在进程中进行程序的执行。一般来说,一个进程可以包含多个线程。
  • 线程是指进程中的一个执行单元,是进程的一部分,它负责在进程中执行程序代码。每个线程都有自己的栈和程序计数器,并且可以共享进程的资源。多个线程可以在同一时刻执行不同的操作,从而提高了程序的执行效率。
  • 现代的操作系统是支持多进程的,也就是可以启动多个软件,一个软件就是一个进程。称为:多进程并发。而通常一个进程都是可以启动多个线程的。称为:多线程并发。
  • 多线程的作用:提高处理效率。(多线程的优点之一是能够使 CPU 在处理一个任务时同时处理多个线程,这样可以充分利用 CPU 的资源,提高 CPU 的利用效率。)
  • JVM规范中规定:堆内存、方法区 是线程共享的。虚拟机栈、本地方法栈、程序计数器 是每个线程私有的。
  • 关于Java程序的运行原理
    ①“java HelloWorld”执行后,会启动JVM,JVM的启动表示一个进程启动了。
    ②JVM进程会首先启动一个主线程(main-thread),主线程负责调用main方法。因此main方法是在主线程中运行的。
    ③除了主线程之外,还启动了一个垃圾回收线程。因此启动JVM,至少启动了两个线程。
    ④在main方法的执行过程中,程序员可以手动创建其他线程对象并启动。

在这里插入图片描述

2.并发与并行

  1. 并发(concurrency)

使用单核CPU的时候,同一时刻只能有一条指令执行,但多个指令被快速的轮换执行,使得在宏观上具有多个指令同时执行的效果,但在微观上并不是同时执行的,只是把时间分成若干端,使多个指令快速交替的执行。
在这里插入图片描述
如上图所示,假设只有一个CPU资源,线程之间要竞争得到执行机会。图中的第一个阶段,在A执行的过程中,B、C不会执行,因为这段时间内这个CPU资源被A竞争到了,同理,第二阶段只有B在执行,第三阶段只有C在执行。其实,并发过程中,A、B、C并不是同时进行的(微观角度),但又是同时进行的(宏观角度)。
在同一个时间点上,一个CPU只能支持一个线程在执行。因为CPU运行的速度很快,CPU使用抢占式调度模式在多个线程间进行着高速的切换,因此我们看起来的感觉就像是多线程一样,也就是看上去就是在同一时刻运行。

  1. 并行(parallellism)
    使用多核CPU的时候,同一时刻,有多条指令在多个CPU上同时执行。
    在这里插入图片描述
    如图所示,在同一时刻,ABC都是同时执行(微观、宏观)。

  2. 并发编程与并行编程
    ① 在CPU比较繁忙(假设为单核CPU),如果开启了很多个线程,则只能为一个线程分配仅有的CPU资源,这些线程就会为自己尽量多抢时间片,这就是通过多线程实现并发,线程之间会竞争CPU资源争取执行机会。
    ② 在CPU资源比较充足的时候,一个进程内的多个线程,可以被分配到不同的CPU资源,这就是通过多线程实现并行。
    ③ 至于多线程实现的是并发还是并行?上面所说,所写多线程可能被分配到一个CPU内核中执行,也可能被分配到不同CPU执行,分配过程是操作系统所为,不可人为控制。所以,如果有人问所写的多线程程序是并发还是并行的?答案其实是都有可能。

总结: 单核CPU上的多线程,只是由操作系统来完成多任务间对CPU的运行切换,并非真正意义上的并发。随着多核CPU的出现,也就意味着不同的线程能被不同的CPU核得到真正意义的并行执行,故而多线程技术得到广泛应用。
不管并发还是并行,都提高了程序对CPU资源的利用率,最大限度地利用CPU资源,而我们使用多线程的目的就是为了提高CPU资源的利用率。

3.线程的调度模型

如果多个线程被分配到一个CPU内核中执行,则同一时刻只能允许有一个线程能获得CPU的执行权,那么进程中的多个线程就会抢夺CPU的执行权,这就是涉及到线程调度策略。
两种调度策略:

  • 分时调度模型
    所有线程轮流使用CPU的执行权,并且平均的分配每个线程占用的CPU的时间。
  • 抢占式调度模型
    让优先级高的线程以较大的概率优先获得CPU的执行权,如果线程的优先级相同,那么就会随机选择一个线程获得CPU的执行权,而Java采用的就是抢占式调用。

4.实现线程

4.1 第一种方式:继承Thread

①编写一个类继承Thread,重写run方法。
②创建线程对象:Thread t = new MyThread();
③启动线程:t.start();

示例代码:

package threadtest;/*** 在java语言中,实现线程有两种方式,第一种方式:* 第一步:编写一个类继承java.lang.Thread* 第二步:重写run()方法* 第三步:new线程对象* 第四步:调用线程对象的start()方法来启动线程*/
public class ThreadTest01 {public static void main(String[] args) {//创建线程对象Thread t = new MyThread();//直接调用run()方法,不会启动新的线程//java中有一个语法规则:对于方法体重的代码,必须遵循自上而下的顺序逐次执行//run()方法不结束,main方法是无法继续执行的//t.run();//调用start()方法,启动线程//java中有一个语法规则:对于方法体中的代码,必须遵循自上而下的顺序逐次执行//start()方法不结束,main方法是无法继续执行的//start()方法瞬间就会结束,因为这个方法的作用是启动一个新的线程,只要新线程启动成功了,start()就结束了t.start();//下面的代码在main方法中,因此其属于在主线程中for (int i = 0; i < 100; i++) {System.out.println("main-->" + i);}}
}/*** 自定义一个线程类* java.lang.Thread本身就是一个线程。* MyThread继承Thread,因此MyThread本身也是一个线程。*/
class MyThread extends Thread{@Overridepublic void run() {for (int i = 0; i < 100; i++) {System.out.println("Thread-->" + i);}}
}

运行结果:

Thread-->0
Thread-->1
Thread-->2
Thread-->3
Thread-->4
Thread-->5
Thread-->6
Thread-->7
Thread-->8
Thread-->9
Thread-->10
Thread-->11
Thread-->12
main-->0
main-->1
main-->2
main-->3
main-->4
main-->5
main-->6
main-->7
main-->8
main-->9
main-->10
main-->11
Thread-->13
main-->12
main-->13
main-->14
main-->15
main-->16
main-->17
main-->18
main-->19
main-->20
main-->21
main-->22
main-->23
main-->24
main-->25
Thread-->14
Thread-->15
Thread-->16
Thread-->17
Thread-->18
Thread-->19
Thread-->20
main-->26
Thread-->21
Thread-->22
Thread-->23
Thread-->24
Thread-->25
Thread-->26
Thread-->27
Thread-->28
Thread-->29
Thread-->30
Thread-->31
Thread-->32
Thread-->33
Thread-->34
Thread-->35
Thread-->36
Thread-->37
Thread-->38
Thread-->39
Thread-->40
Thread-->41
Thread-->42
Thread-->43
Thread-->44
Thread-->45
Thread-->46
Thread-->47
Thread-->48
Thread-->49
Thread-->50
Thread-->51
Thread-->52
Thread-->53
Thread-->54
Thread-->55
Thread-->56
Thread-->57
Thread-->58
Thread-->59
main-->27
Thread-->60
Thread-->61
Thread-->62
Thread-->63
Thread-->64
Thread-->65
Thread-->66
Thread-->67
main-->28
main-->29
main-->30
main-->31
main-->32
main-->33
main-->34
main-->35
main-->36
main-->37
main-->38
main-->39
main-->40
main-->41
main-->42
main-->43
Thread-->68
Thread-->69
Thread-->70
Thread-->71
Thread-->72
Thread-->73
Thread-->74
main-->44
Thread-->75
Thread-->76
Thread-->77
Thread-->78
Thread-->79
Thread-->80
main-->45
main-->46
Thread-->81
Thread-->82
Thread-->83
Thread-->84
Thread-->85
Thread-->86
Thread-->87
Thread-->88
Thread-->89
Thread-->90
main-->47
main-->48
Thread-->91
Thread-->92
Thread-->93
Thread-->94
main-->49
Thread-->95
Thread-->96
Thread-->97
Thread-->98
Thread-->99
main-->50
main-->51
main-->52
main-->53
main-->54
main-->55
main-->56
main-->57
main-->58
main-->59
main-->60
main-->61
main-->62
main-->63
main-->64
main-->65
main-->66
main-->67
main-->68
main-->69
main-->70
main-->71
main-->72
main-->73
main-->74
main-->75
main-->76
main-->77
main-->78
main-->79
main-->80
main-->81
main-->82
main-->83
main-->84
main-->85
main-->86
main-->87
main-->88
main-->89
main-->90
main-->91
main-->92
main-->93
main-->94
main-->95
main-->96
main-->97
main-->98
main-->99Process finished with exit code 0

直接调用run()方法的内存结构图:
在这里插入图片描述

调用start()方法的内存结构图:
在这里插入图片描述

4.2 第二种方式:实现Runnable接口

①编写一个类实现Runnable接口,实现run方法。
②创建线程对象:Thread t = new Thread(new MyRunnable());
③启动线程:t.start();

示例代码:

package threadtest;/*** 在java语言中,实现线程有两种方式,第二种方式:* 第一步:编写一个类实现java.lang.Runnable接口(可运行接口)* 第二步:实现接口中的run方法* 第三步:new线程对象* 第四步:调用线程的start方法启动线程*/
public class ThreadTest02 {public static void main(String[] args) {//创建Runnable对象Runnable r = new MyRunnable();//创建线程对象Thread t = new Thread(r);//启动线程t.start();for (int i = 0; i < 100; i++) {System.out.println("main-->" + i);}}
}/*** 创建一个类实现Runnable接口*/
class MyRunnable implements Runnable{@Overridepublic void run() {for (int i = 0; i < 100; i++) {System.out.println("Thread-->" + i);}}
}

运行结果:

main-->0
Thread-->0
Thread-->1
Thread-->2
Thread-->3
Thread-->4
Thread-->5
Thread-->6
Thread-->7
Thread-->8
Thread-->9
Thread-->10
Thread-->11
Thread-->12
Thread-->13
main-->1
main-->2
Thread-->14
Thread-->15
Thread-->16
Thread-->17
Thread-->18
Thread-->19
Thread-->20
Thread-->21
Thread-->22
Thread-->23
main-->3
main-->4
main-->5
main-->6
main-->7
main-->8
main-->9
main-->10
main-->11
main-->12
main-->13
main-->14
main-->15
main-->16
main-->17
main-->18
Thread-->24
Thread-->25
Thread-->26
Thread-->27
Thread-->28
Thread-->29
Thread-->30
Thread-->31
Thread-->32
Thread-->33
Thread-->34
Thread-->35
Thread-->36
Thread-->37
Thread-->38
Thread-->39
Thread-->40
Thread-->41
Thread-->42
Thread-->43
Thread-->44
Thread-->45
Thread-->46
Thread-->47
Thread-->48
Thread-->49
Thread-->50
Thread-->51
Thread-->52
Thread-->53
Thread-->54
Thread-->55
Thread-->56
Thread-->57
Thread-->58
Thread-->59
Thread-->60
Thread-->61
Thread-->62
Thread-->63
Thread-->64
Thread-->65
main-->19
main-->20
Thread-->66
Thread-->67
Thread-->68
Thread-->69
Thread-->70
Thread-->71
Thread-->72
Thread-->73
Thread-->74
Thread-->75
Thread-->76
Thread-->77
Thread-->78
Thread-->79
Thread-->80
Thread-->81
Thread-->82
Thread-->83
Thread-->84
Thread-->85
Thread-->86
Thread-->87
Thread-->88
Thread-->89
Thread-->90
Thread-->91
Thread-->92
Thread-->93
Thread-->94
Thread-->95
Thread-->96
Thread-->97
Thread-->98
Thread-->99
main-->21
main-->22
main-->23
main-->24
main-->25
main-->26
main-->27
main-->28
main-->29
main-->30
main-->31
main-->32
main-->33
main-->34
main-->35
main-->36
main-->37
main-->38
main-->39
main-->40
main-->41
main-->42
main-->43
main-->44
main-->45
main-->46
main-->47
main-->48
main-->49
main-->50
main-->51
main-->52
main-->53
main-->54
main-->55
main-->56
main-->57
main-->58
main-->59
main-->60
main-->61
main-->62
main-->63
main-->64
main-->65
main-->66
main-->67
main-->68
main-->69
main-->70
main-->71
main-->72
main-->73
main-->74
main-->75
main-->76
main-->77
main-->78
main-->79
main-->80
main-->81
main-->82
main-->83
main-->84
main-->85
main-->86
main-->87
main-->88
main-->89
main-->90
main-->91
main-->92
main-->93
main-->94
main-->95
main-->96
main-->97
main-->98
main-->99Process finished with exit code 0

总结:
优先选择第二种方式:因为实现接口的同时,保留了类的继承。
第二种方式也可以使用匿名内部类如下:

Thread t = new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 100; i++) {System.out.println("main-->" + i);}  }});
t.start();

4.3 t.start()和t.run()的本质区别?

本质上没有区别,都是普通方法调用。只不过两个方法完成的任务不同。

  • t.run()是调用run方法。执行run方法中的业务代码。
  • t.start()是启动线程,只要线程启动了,start()方法就执行结束了。

4.4 线程常用的三个方法

实例方法:
①String getName(); 获取线程对象的名字;
②void setName(String name);修改线程对象的名字。
静态方法:
①static Thread currentThread();获取当前线程对象的引用。

package threadtest;public class ThreadTest03 {public static void main(String[] args) {Thread t1 = new MyNewThread();t1.start();Thread t2 = new MyNewThread();t2.start();Thread thread = Thread.currentThread();System.out.println("当前运行线程:" + thread.getName());}
}class MyNewThread extends Thread{@Overridepublic void run() {//获取当前运行线程的引用Thread t = Thread.currentThread();//获取当前运行线程的名字System.out.println("当前运行线程:" + t.getName()); }
}

运行结果:
在这里插入图片描述
创建线程时,若没有给线程指定名字,则会给对应线程赋上默认的名字:Thread-xx
可以修改线程名字:

package threadtest;public class ThreadTest03 {public static void main(String[] args) {Thread t1 = new MyNewThread();t1.setName("t1");t1.start();Thread t2 = new MyNewThread();t2.setName("t2");t2.start();Thread thread = Thread.currentThread();System.out.println("当前运行线程:" + thread.getName());}
}class MyNewThread extends Thread{@Overridepublic void run() {//获取当前运行线程的引用Thread t = Thread.currentThread();//获取当前运行线程的名字System.out.println("当前运行线程:" + t.getName());}
}

运行结果:
在这里插入图片描述

也可以在创建线程时,通过构造方法为线程指定名字:

package threadtest;public class ThreadTest03 {public static void main(String[] args) {Thread t1 = new MyNewThread("tt1");
//        t1.setName("t1");t1.start();Thread t2 = new MyNewThread("tt2");
//        t2.setName("t2");t2.start();Thread thread = Thread.currentThread();System.out.println("当前运行线程:" + thread.getName());}
}class MyNewThread extends Thread{public MyNewThread() {}//有参构造方法public MyNewThread(String name) {super(name);}@Overridepublic void run() {//获取当前运行线程的引用Thread t = Thread.currentThread();//获取当前运行线程的名字System.out.println("当前运行线程:" + t.getName());}
}

运行结果:
在这里插入图片描述

5.线程的生命周期(把生命周期图背会)

线程的生命周期有7个状态:

  1. 新建状态;
  2. 就绪状态;
  3. 运行状态
  4. 超时等待状态;
  5. 等待状态(wait()方法);
  6. 阻塞状态(线程同步机制);
  7. 终止状态。
    在这里插入图片描述

5.1 Thread.sleep()方法

static void sleep(long millis):静态方法,没有返回值,参数是为毫秒单位的时间,1秒=1000毫秒。
作用:让当前线程进入休眠,即让当前线程放弃占有的CPU时间片,使其进入超时等待状态。等待时间以设定的毫秒数为准,在该指定的时间范围内,当前线程没有权利抢夺CPU时间片。
如何理解“当前线程”:Thread.sleep(1000),这个代码出现在哪个线程中,这个线程就是“当前线程”。

示例代码:

package threadtest;public class ThreadTest04 {public static void main(String[] args) {//让主线程睡眠5秒try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}for (int i = 0; i < 5; i++) {System.out.println(Thread.currentThread().getName() + "====>" + i);}Runnable r = new MyNewRunnable();Thread t = new Thread(r);t.start();}}class MyNewRunnable implements Runnable{//run方法在重写时不能在方法声明位置使用 throws 抛出异常,子类不能比父类抛出更多异常,所以这里只能try...catch@Overridepublic void run() {for (int i = 0; i < 10; i++) {System.out.println(Thread.currentThread().getName() + "====>" + i);//让当前线程睡眠1秒再进入下一次循环try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}
}

5.1.1 关于Thread.sleep()的面试题

package threadtest;public class ThreadTest05 {public static void main(String[] args) {MyLatestThread t = new MyLatestThread();t.setName("t");t.start();try {t.sleep(3000);  //当前代码是让t线程睡眠3秒吗?} catch (InterruptedException e) {e.printStackTrace();}for (int i = 0; i < 10; i++) {System.out.println(Thread.currentThread().getName() + "====>" + i);}}
}class MyLatestThread extends Thread{@Overridepublic void run() {for (int i = 0; i < 10; i++) {System.out.println(Thread.currentThread().getName() + "====>" + i);}}
}

以上t.sleep(3000);并不是让t线程睡眠,而是让当前线程,即主线程main线程睡眠。

5.2 如何中断一个线程的睡眠

语法:线程对象.interrupt(true);
示例代码:

package threadtest.thread06;public class ThreadTest06 {public static void main(String[] args) {//创建线程Thread t = new MyThread();t.setName("t");//启动线程t.start();//要求5秒之后睡眠的t线程起来干活try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}//终止t线程的睡眠//其底层原理是利用了异常处理机制:当调用这个方法时,如果t线程正在睡眠,必然会抛出:InterruptedException,然后捕捉异常,终止睡眠t.interrupt();}
}class MyThread extends Thread{@Overridepublic void run() {System.out.println(Thread.currentThread().getName() + "--> begin");try {//睡眠一年Thread.sleep(1000*60*60*24*365);} catch (InterruptedException e) {System.out.println("睡眠中断了!");e.printStackTrace();}//睡眠一年之后,起来干活了System.out.println(Thread.currentThread().getName() + " --> work!");}
}

运行结果:
在这里插入图片描述

5.3 如何强行终止一个线程

5.3.1 已过时的方式

语法:线程对象.stop();
如下代码:

package threadtest.thread07;public class ThreadTest07 {public static void main(String[] args) {Thread t = new Thread(new MyRunnable());t.setName("t");t.start();//当前线程睡眠5秒try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}//终止t线程的执行,从java2开始就不建议使用了,因为这种方式是强行终止线程,容易导致数据丢失。t.stop();}
}class MyRunnable implements Runnable{@Overridepublic void run() {for (int i = 0; i < 10; i++) {System.out.println(Thread.currentThread().getName() + "-->" + i);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}
}

运行结果:
在这里插入图片描述

5.3.2 推荐的方式

设置标记。
如下代码:

package threadtest.thread08;public class ThreadTest08 {public static void main(String[] args) {MyRunnable r = new MyRunnable();Thread t = new Thread(r);t.setName("t");t.start();//当前线程睡眠5秒try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}//修改标记,终止线程t的执行r.ifRun = false;}
}class MyRunnable implements Runnable{//设置标记boolean  ifRun = true;@Overridepublic void run() {for (int i = 0; i < 10; i++) {if(ifRun){System.out.println(Thread.currentThread().getName() + "-->" + i);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}else{return;}}}
}

运行结果:
在这里插入图片描述

5.4 守护线程

在java语言中,线程被分为两大类:

  1. 用户线程(非守护线程)【上面例子中定义的线程,包括主线程,都是用户线程】;
  2. 守护线程(后台线程)。

在JVM中有一个隐藏的守护线程:GC线程。
守护线程的特点:所有用户线程结束之后,守护线程自动退出/结束。

设置一个线程为守护线程(需要在线程启动前设置):线程对象.setDaemon(true);

示例代码:

package threadtest.thread09;public class ThreadTest09 {public static void main(String[] args) {Thread t = new MyThread();t.setName("t");//需要再t线程启动前,设置t线程为守护线程,所有用户线程结束守护线程自动结束t.setDaemon(true);//启动t线程t.start();//设置main用户线程10秒后结束for (int i = 0; i < 10; i++) {System.out.println(Thread.currentThread().getName() + "-->" + i);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}   }
}class MyThread extends Thread{@Overridepublic void run() {int i = 0;//死循环while (true){System.out.println(Thread.currentThread().getName() + " --> " + (++i));try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}
}

运行结果:
在这里插入图片描述

5.5 定时器

JDK中提供的定时任务:

  • java.util.Timer:定时器
  • java.util.TimerTask:定时任务
    定时器+定时任务可以帮我们在程序中完成:指定时间开始,每间隔多久执行一次某段程序。

Timer的构造方法:

  • Timer();
  • Timer(boolean isDaemon): isDaemon为true表示该定时器是一个守护线程。

Timer的一个方法:

  • schedule(TimerTask task, Date firstTime, long period):task为需要执行的任务,firstTime为第一次执行时间,period为每隔多久执行一次(单位:毫秒)。
package threadtest.thread10;import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.TimerTask;/*** 定时任务类TimerTask是一个抽象类,其实现了Runnable接口,所以继承该类需要覆写run()方法*/
public class LogTimerTask extends TimerTask {int i = 1;SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SSS");@Overridepublic void run() {Date now = new Date();String strTime = dateFormat.format(now);System.out.println(strTime + " " + (i++));}
}
package threadtest.thread10;import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Timer;public class ThreadTest10 {public static void main(String[] args) throws Exception {//创建定时器对象(其本质上就是一个线程)//如果这个定时器执行的任务是一个后台任务,建议将其定义为守护线程Timer timer = new Timer(true);SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");Date firstTime = dateFormat.parse("2024-03-26 17:45:00");//指定定时任务为LogTimerTask,第一次执行时间为firstTime,每间隔1秒执行一次。timer.schedule(new LogTimerTask(), firstTime,1000);//main线程5秒后结束,则上述守护线程也随之结束for (int i = 0; i < 5; i++) {Thread.sleep(1000);}}
}

运行结果:
在这里插入图片描述

5.6 线程合并

join()方法是一个实例方法,线程对象调用join()方法完成线程合并。

Thread t = new Thread();
t.setName("t");
t.join();

t.join方法其实是让当前线程进入阻塞状态,直到t线程结束,当前线程阻塞解除。
假设在main方法(main线程)中调用了t.join()方法,则为将t线程合并到main线程中,main线程进入阻塞状态,直到t线程执行结束,main线程解除阻塞。

join()方法和sleep()方法的联系和区别:

  1. sleep()方法和join()方法都是让当前线程进入阻塞状态(超时等待状态因也可以看作是一种阻塞状态);
  2. sleep()方法是静态方法,而join()方法是实例方法;
  3. sleep()方法可以指定睡眠的时长,而join()方法不能保证阻塞的时长;
  4. sleep()方法的阻塞解除条件:设置的时间过去了;join()方法的阻塞解除条件:调用join()方法的那个线程结束了。

示例代码:

package threadtest.thread11;public class ThreadTest11 {public static void main(String[] args) throws InterruptedException {Thread t = new MyThread();t.setName("t");t.start();//合并线程,将t线程合并到main线程中,main线程收到阻塞,t线程继续执行,直到t线程结束,main线程阻塞解除t.join();System.out.println("main begin");//主线程for (int i = 0; i < 20; i++) {System.out.println(Thread.currentThread().getName() + "-->" + i);}System.out.println("main over");}
}class MyThread extends Thread{@Overridepublic void run() {for (int i = 0; i < 20; i++) {System.out.println(Thread.currentThread().getName() + "-->" + i);}}
}

运行结果:

t-->0
t-->1
t-->2
t-->3
t-->4
t-->5
t-->6
t-->7
t-->8
t-->9
t-->10
t-->11
t-->12
t-->13
t-->14
t-->15
t-->16
t-->17
t-->18
t-->19
main begin
main-->0
main-->1
main-->2
main-->3
main-->4
main-->5
main-->6
main-->7
main-->8
main-->9
main-->10
main-->11
main-->12
main-->13
main-->14
main-->15
main-->16
main-->17
main-->18
main-->19
main overProcess finished with exit code 0

join()方法也可以有参数,参数是毫秒,表示线程合并时长。

package threadtest.thread11;public class ThreadTest11 {public static void main(String[] args) throws InterruptedException {Thread t = new MyThread();t.setName("t");t.start();//合并线程,将t线程合并到main线程中,main线程受到阻塞,t线程继续执行,直到t线程结束,main线程阻塞解除//合并时长为10毫秒,即只阻塞当前线程10毫秒,但并不一定能达到设置的阻塞时长,如果在指定的时间内,t线程早就结束了,则阻塞就立即解除了。t.join(10);System.out.println("main begin");//主线程for (int i = 0; i < 20; i++) {System.out.println(Thread.currentThread().getName() + "-->" + i);}System.out.println("main over");}
}class MyThread extends Thread{@Overridepublic void run() {for (int i = 0; i < 20; i++) {System.out.println(Thread.currentThread().getName() + "-->" + i);}}
}

5.7 线程优先级

线程是可以设置优先级的,JVM采用的是抢占式调度模型,优先级高的线程获取CPU时间片的总体概率会高一些。
默认情况下一个线程的优先级是5,最低为1,最高为10。

package threadtest.thread12;public class ThreadTest12 {public static void main(String[] args) {System.out.println("最低优先级" + Thread.MIN_PRIORITY);System.out.println("最高优先级" + Thread.MAX_PRIORITY);System.out.println("默认优先级" + Thread.NORM_PRIORITY);//获取线程的优先级System.out.println("当前线程优先级:" + Thread.currentThread().getPriority());//设置优先级Thread.currentThread().setPriority(10);System.out.println("当前线程优先级:" + Thread.currentThread().getPriority());}
}

运行结果:
在这里插入图片描述
给多个线程设置不同优先级:

package threadtest.thread12;public class ThreadTest12 {public static void main(String[] args) {Thread t1 = new MyThread();t1.setName("t1");Thread t2 = new MyThread();t2.setName("t2");//设置t1为最高优先级,t2为最低优先级,相对来说t1指定的概率高一些t1.setPriority(Thread.MAX_PRIORITY); t2.setPriority(Thread.MIN_PRIORITY);t1.start();t2.start();}
}class MyThread extends Thread{@Overridepublic void run() {for (int i = 0; i < 1000; i++) {System.out.println(Thread.currentThread().getName() + "-->" + i);}}
}

5.8 线程让位

静态方法:Thread.yield(),当前线程让位。
注意:让位不会使当前线程进入阻塞状态,只是放弃目前占有的CPU时间片,进入就绪状态,继续抢夺CPU时间片。
示例代码:

package threadtest.thread13;/*** 线程让位*/
public class ThreadTest13 {public static void main(String[] args) {Thread t1 = new MyThread();t1.setName("t1");Thread t2 = new MyThread();t2.setName("t2");t1.start();t2.start();}
}class MyThread extends Thread{@Overridepublic void run() {for (int i = 0; i < 100; i++) {if(Thread.currentThread().getName().equals("t1") && i%10 == 0){ //当前线程为t1线程,且i为10的倍数时,进行线程让位System.out.println(Thread.currentThread().getName() + "让位了,此时i=" + i);//注意:t1线程让位只是放弃当前占有的时间片,至于后续时间片被哪个线程抢占并不一定,也有可能t1会继续抢到Thread.yield();}System.out.println(Thread.currentThread().getName() + "==>" + i);}}
}

运行结果就不贴了。

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

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

相关文章

蓝桥杯 历届真题 双向排序【第十二届】【省赛】【C组】

资源限制 内存限制&#xff1a;256.0MB C/C时间限制&#xff1a;1.0s Java时间限制&#xff1a;3.0s Python时间限制&#xff1a;5.0s 改了半天只有60分&#xff0c;还是超时&#xff0c;还不知道怎么写&#xff0c;后面再看吧┭┮﹏┭┮ #include<bits/stdc.h> …

在线聊天使用说明

功能 支持世界聊天没有人数限制支持个人聊天支持群聊(没开放)支持通讯录支持添加好友支持添加群(没开放)支持emoji表情后期会支持发送图片现在还不支持 现有问题可能样式兼容还有点问题, 以后有时间在处理, 目前能正常聊天 入口 聊天入口: https://huanmin.top/#/chat 功…

必知必会!使用NumPy对数组进行拆分

使用NumPy对数组进行拆分是一种高效且灵活的数据处理方式。NumPy提供了多种函数&#xff0c;如numpy.split(), numpy.hsplit(), 和 numpy.vsplit()&#xff0c;使得数组可以根据不同的需求进行拆分。这些函数能够精确控制拆分的数量和位置&#xff0c;满足不同的数据处理和分析…

2024/4/1—力扣—按摩师

代码实现&#xff1a; 思路&#xff1a;打家劫舍题 int massage(int *nums, int numsSize) {if (nums NULL || numsSize 0) {return 0;}if (numsSize 1) {return nums[0];}int dp[numsSize];memset(dp, 0, sizeof(dp));dp[0] nums[0];dp[1] (nums[0] < nums[1] ? nums…

【NLP】多标签分类【下】

文章目录 简介个人博客与相关链接1 实验数据与任务说明2 模型介绍2.1 TransformerTransformer能做什么&#xff1f; 2.2 Hugging FaceHugging Face的Transformers库社区支持和资源预训练模型的应用 2.3 T5模型&#xff08;Text-To-Text Transfer Transformer&#xff09;T5的核…

时间系列预测总结

转载自&#xff1a;https://mp.weixin.qq.com/s/B1eh4IcHTnEdv2y0l4MCog 拥有一种可靠的方法来预测和预测未来事件一直是人类的愿望。在数字时代&#xff0c;我们拥有丰富的信息&#xff0c;尤其是时间序列数据。 时间序列是指基于时间刻度维度&#xff08;天、月、年等&…

【THM】Protocols and Servers 2(协议和服务器 2

介绍 协议和服务器房间涵盖了许多协议: 远程登录HTTP协议文件传输协议邮件传输协议POP3IMAP实现这些协议的服务器会受到不同类型的攻击。仅举几例,请考虑: 嗅探攻击(网络数据包捕获)中间人 ( MITM ) 攻击密码攻击(身份验证攻击)漏洞从安全的角度来看,我们始终需要思考…

用API技术为数据安全“上保险”——双重保障

&#x1f50d;API在数据安全领域的核心地位 随着数字化进程的狂飙突进&#xff0c;应用程序接口&#xff08;API&#xff09;已化身为企业内部、不同平台间以及用户交互的关键纽带。它们不仅是数据流动与共享的驱动引擎&#xff0c;更是守护数据安全的重要防线。其中&#xf…

端口敲击守护程序之DC-9

总结 getwebshell : 发现SQL注入 → 登录系统 → 疑似文件包含 → FUZZ参数 → 文件包含读取守护程序 → 敲击打开SSH端口 → 利用泄露账号密码登录 提 权 思 路 : 发现3个用户 → 登录获取密码字典 → 再次爆破获取第4个用户 → sudo文件发现 → 存在root权限写入功能 → pa…

共生共舞的期货黄金和现货黄金

期货黄金&#xff0c;作为一种在金融市场上备受关注的投资工具&#xff0c;其价值与价格走势深受现货黄金市场的直接影响和联动。期货黄金交易&#xff0c;本质上是投资者对未来某一特定时间内黄金价格的预期进行押注&#xff0c;而这背后的逻辑支撑和价格基准正是现货黄金市场…

2024通信技术与航空航天工程国际会议(ICCTAE2024)

2024通信技术与航空航天工程国际会议(ICCTAE2024) 会议简介 通信技术和航空航天领域有着密切的关联和深远的意义。 随着通信技术和航空航天工程的快速发展&#xff0c;这两个领域的交叉融合为学术界和工业界提供了广阔的研究空间和实际应用前景。为了进一步推动相关领域的发…

Ubuntu 20.04.06 PCL C++学习记录(二十)

[TOC]PCL中点云分割模块的学习 学习背景 参考书籍&#xff1a;《点云库PCL从入门到精通》以及官方代码PCL官方代码链接,&#xff0c;PCL版本为1.10.0&#xff0c;CMake版本为3.16 学习内容 基于颜色的区域增长细分 源代码及所用函数 源代码 #include<iostream> #i…

HIS系统是什么?一套前后端分离云HIS系统源码 接口技术RESTful API + WebSocket + WebService

HIS系统是什么&#xff1f;一套前后端分离云HIS系统源码 接口技术RESTful API WebSocket WebService 医院管理信息系统(全称为Hospital Information System)即HIS系统。 常规模版包括门诊管理、住院管理、药房管理、药库管理、院长查询、电子处方、物资管理、媒体管理等&…

Grafana告警(邮件)自定义模板配置

一年前给客户部署配置过grafana&#xff0c;告警配置也是用的原始的&#xff0c;客户在使用过程中只需要一些核心点信息&#xff0c;想要实现这个就需要用Grafana的自定义告警模板以及编辑邮件模板。 通知模板 模板信息的配置中查阅了相关资料&#xff0c;自己组装了一套&…

【IC前端虚拟项目】spyglass lint环境组织与lint清理

【IC前端虚拟项目】数据搬运指令处理模块前端实现虚拟项目说明-CSDN博客 和上个虚拟项目的lint清理环节一样&#xff0c;关于spyglass的lint清理功能与流程还是大家通过各种资料去学习下就好啦。和之前不同的事&#xff0c;这次的虚拟项目里我把流程封装为Makefile&#xff0c;…

三流大学毕业,物流专业转行自述:“从月薪4K到现在月入2W+,我做到了哪些?”

我是25岁转行学python的。说实在&#xff0c;转行就是奔着挣钱去的。希望我的经历可以给想转行的朋友带来一点启发和借鉴。 先简单介绍下个人背景&#xff0c;三流大学毕业&#xff0c;物流专业&#xff0c;学习能力一般&#xff0c;没啥特别技能&#xff0c;反正就很普通的一…

C++ //练习 11.23 11.2.1节练习(第378页)中的map以孩子的姓为关键字,保存他们的名的vector,用multimap重写此map。

C Primer&#xff08;第5版&#xff09; 练习 11.23 练习 11.23 11.2.1节练习&#xff08;第378页&#xff09;中的map以孩子的姓为关键字&#xff0c;保存他们的名的vector&#xff0c;用multimap重写此map。 环境&#xff1a;Linux Ubuntu&#xff08;云服务器&#xff09;…

flutter 获取验证码倒计时组件封装

send_sms_btn.dart import dart:async;import package:flutter/material.dart; import package:get/get.dart;// 发送验证码 按钮 class SendSmsBtn extends StatefulWidget {final Future<bool> Function()? onTap;const SendSmsBtn({super.key,this.onTap,});overrid…

CS162 Operating System笔记

What is an Operating System? it’s typically a special layer of software that provides the application access to hardware resources.So.it’s convenient abs fractions of complex hardware devices.

FHE全同态加密简介

1. 何为FHE&#xff1f; FHE (Fully homomorphic encryption)&#xff1a; 是一种隐私技术&#xff0c;支持直接对密文进行计算&#xff0c;而无需对密文先解密再计算。即&#xff0c;任何第三方或云厂商&#xff0c;都可对敏感信息的密文进行处理&#xff0c;而无需访问密文内…