Java并发编程核心_如何关闭一个线程

捕获中断信号关闭线程

package com.neu.day02;

import java.util.concurrent.TimeUnit;

/**
* @Author yqq
* @Date 2022/03/27 18:50
* @Version 1.0
*/
public class Thread05 {
public static void main(String[] args) throws InterruptedException{
Thread t = new Thread(){
@Override
public void run() {
System.out.println("I will start work.");
while (!this.isInterrupted()){
System.out.println("I an working");
}
System.out.println("I will be exiting");
}
};
t.start();
TimeUnit.SECONDS.sleep(5);
System.out.println("System will be shutdown");
t.interrupt();
}
}

使用 volatile 开关控制

package com.neu.day02;

import java.util.concurrent.TimeUnit;

/**
* @Author yqq
* @Date 2022/03/27 19:02
* @Version 1.0
*/
public class Thread06 {
public static void main(String[] args) throws InterruptedException{
Mytask t = new Mytask();
t.start();
TimeUnit.SECONDS.sleep(5);
System.out.println("System will be shutdown");
t.close();
}
}

class Mytask extends Thread{

private volatile boolean closed = false;

@Override
public void run() {
System.out.println("I will start work.");
while (!closed && isInterrupted()){
System.out.println("I an working");
}
System.out.println("I will be exiting");
}
public void close(){
this.closed = true;
this.interrupt();
}
}