大家好,今天为大家带来Thread类的基本方法,咱们接着上期继续讲
目录
🎉 1.线程中断
🎉 2.线程等待
🎉3.线程休眠
🎉4.获取线程实例
🎉5.线程的状态
1.线程中断
上一期说的is Interrupted()就是说线程被中断的事情
线程是否被中断取决于线程 的入口方法是否已经执行完毕
进行线程中断只有一个办法:让线程的入口方法执行完毕(要么return,要么抛异常)
1.给线程设定一个结束标志位
上代码
public class ThreadDemo1 { 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); } catch (InterruptedException e) { throw new RuntimeException(e); } } System.out.println("线程结束"); }); t.start(); try { Thread.sleep(3000); } catch (InterruptedException e) { throw new RuntimeException(e); } //主线程中修改isQuit的值 isQuit=true; } }
这里为啥一定要把isQuit设置为静态全局变量呢,因为如果放在lambda表达式里,会进行变量捕获,有两个要求,设置的变量必须是final修饰或者是实际final的,啥意思呢
final修饰的就是个常量了
实际final指的是虽然不是个常量,,没有用final修饰,但是没有尝试去修改它的值
而如果这个代码中将isQuit放入lambda表达式中,在主线程中对它又进行了修改,所以会报错.所以最好的方式就是将它作为静态全局变量
如图所示,我们可以看到报红了
上述是一种方式,需要程序员手动设置标志位,那么我们也可以采用Thread类内置的标志位来进行
线程中断
上代码来进行更好的讲解
public class ThreadDemo2 { //currentThread是获取当前线程实例的方法 //isInterrupted是t对象自带的一个标志位 //interrupt方法就是设置标志位为true public static void main(String[] args) { Thread t=new Thread(()->{ 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.interrupt(); } }
我们先来运行一下这个代码,看看结果
发现了吗,这个线程并没有结束,而是打印了三次,抛出异常,然后继续执行
代码中的e.printStackPrace()打印的是异常调用栈
为啥线程没有按照预期结束呢
首先主线程休眠3000ms,t线程打印三次,这时isInterrupted本身是false,然后主线程苏醒,,调用interrupt方法,将标志位边为true,这时候t线程执行到了sleep那里,那么sleep被提前唤醒,清空了标志位,将true再次变为false,那么这个循环一直为真,也就会一直执行了
那么我们要怎样解决这个问题呢
手动加break
public class ThreadDemo2 { //currentThread是获取当前线程实例的方法 //isInterrupted是t对象自带的一个标志位 //interrupt方法就是设置标志位为true public static void main(String[] args) { Thread t=new Thread(()->{ 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.interrupt(); } }
看运行结果
那么为什么sleep要清空标志位呢
让线程对于啥时候结束有一个更精准的控制
使用interrupt不是让线程立即结束,而是告诉线程应该结束了,真正线程结束取决于我们怎样写代码😊
2.线程等待
线程之间是并发执行的,对于线程调度是无序的,我们要想确定线程执行顺序,需要使用线程等待
线程等待这个比较简单,就是使用join,来举个例子
public class ThreadDemo3 { 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()意思是让主线程阻塞等待,t线程结束以后,再执行主线程
这里有一个误区,让主线程阻塞不是说除了t线程其他所有线程都阻塞了,而是除了主线程阻塞,其他线程照常执行,不受影响
这样就保证了线程的执行顺序
如果主线程中调用t.join()时,t正在执行,那么主线程就阻塞等待,直到t线程结束,主线程接着执行
如果主线程调用t.join()时,t已经执行完毕,那么主线程就直接执行即可
3.线程休眠
已经写过很多遍了,就是sleep,就不再赘述了
下一个问题
线程获取实例,
在讲线程中断的时候,也讲过了,currenrtThread()方法就是获取一个线程的实例
线程状态
1.NEW(线程还未创建,就是有个Thread对象)
2.RUNNABLE(正在CPU调度或者即将上CPU调度)
3.TERMINATED(线程已经执行完毕,Thread对象还在)
4.BLOCKED(等待锁出现的状态)
5.TIME_WAITING(指定时间等待.sleep方法)
6.WAITING(使用wait方法出现的状态)
下面通过代码来看一看
public class ThreadDemo12 { public static void main(String[] args) throws InterruptedException { Thread t = new Thread(() -> { while (true) { // System.out.println("hello"); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } }); // 在启动之前, 获取线程状态. NEW System.out.println(t.getState()); t.start(); //Thread.sleep(2000); System.out.println(t.getState()); } }
public class ThreadDemo12 { public static void main(String[] args) throws InterruptedException { Thread t = new Thread(() -> { while (true) { // 为了防止 hello会将线程状态覆盖掉 , 先注释这一行 // System.out.println("hello"); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } }); // 未启动,NEW System.out.println(t.getState()); t.start(); Thread.sleep(2000); System.out.println(t.getState()); } }
总结
线程的状态
NEW
RUNNABLE
TERMINATED
这三个状态是线程的主要状态
然后BLOCKED,TIME_WAITING,WAITING,都是线程执行中可能出现的状态,
简称,一条主线,三个分支,BLOCKED和WAITING后期再讲
今天的讲解就到这里,我们下期再见,886!!!
