如何在不使用退出标志的情况下终止Java线程？

当前代码调用interrupt()后，生产者线程仍在运行。因为生产者的run()方法是无响应中断的死循环，且由于生产者需要执行网络请求、无法预估响应时间，不能依赖自定义标志来控制线程终止。

原代码 #

public class SOQuestion1 {

    public static void main(String[] args) {
        ProducerThread producerThread1 = new ProducerThread();
        ProducerThread producerThread2 = new ProducerThread();
        
        ControllerThread1 controllerThread1 = 
                new ControllerThread1(producerThread1);
        
        controllerThread1.start();
        
        ControllerThread2 controllerThread2 = 
                new ControllerThread2(producerThread2);
        
        controllerThread2.start();
    }
}

class ProducerThread extends Thread {
    
    @Override
    public void run() {
        while (true);
    }
}

class ControllerThread1 extends Thread {
    
    private final ProducerThread producerThread;
    
    ControllerThread1(ProducerThread producerThread) {
        this.producerThread = producerThread;
    }
    
    @Override
    public void run() {
        producerThread.start();
        System.out.println("Started ControllerThread1.");
        
        try {
            producerThread.join(2000);
            
            Thread.sleep(2000);
            producerThread.interrupt();
        } catch (InterruptedException ex) {
            ex.printStackTrace();
        }
        
        System.out.println("Joined ControllerThread1.");
    }
}

class ControllerThread2 extends Thread {
    
    private final ProducerThread producerThread;
    
    ControllerThread2(ProducerThread producerThread) {
        this.producerThread = producerThread;
    }
    
    @Override
    public void run() {
        producerThread.start();
        System.out.println("Started ControllerThread2.");
        
        try {
            Thread.sleep(2000);
            producerThread.interrupt();
        } catch (InterruptedException ex) {
            ex.printStackTrace();
        }
        
        System.out.println("Joined ControllerThread2.");
    }
}

程序输出 #

Started ControllerThread1.
Started ControllerThread2.
Joined ControllerThread2.
Joined ControllerThread1.

解决方案 #

核心思路是让生产者线程正确响应中断信号，利用Java线程的中断机制，结合网络IO操作对中断的响应特性来终止线程，无需依赖自定义标志。

1. 修改生产者线程，使其响应中断 #

生产者线程需要在循环中检查中断状态，同时处理网络操作时的中断异常：

class ProducerThread extends Thread {
    
    @Override
    public void run() {
        // 循环条件检查当前线程的中断状态
        while (!Thread.currentThread().isInterrupted()) {
            try {
                // 替换为实际的网络加载逻辑，比如HttpClient请求、URLConnection
                // 这里用Thread.sleep模拟网络阻塞操作
                System.out.println("生产者线程正在加载网络数据...");
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // 捕获中断异常，终止线程
                System.out.println("生产者线程收到中断信号，开始终止");
                // 重置中断状态（异常抛出后中断标志会被清除）
                Thread.currentThread().interrupt();
                // 跳出循环，结束线程
                break;
            } catch (IOException e) {
                // 处理网络请求异常，可根据业务决定是否继续或终止
                e.printStackTrace();
            }
        }
        System.out.println("生产者线程已终止");
    }
}

2. 控制器线程无需修改 #

原有的ControllerThread1和ControllerThread2调用producerThread.interrupt()的逻辑是正确的，只要生产者线程能响应中断，就能被正常终止。

3. 原代码失效原因 #

原生产者线程是忙循环（while(true)），既没有阻塞操作，也不检查中断状态，调用interrupt()只会设置线程的中断标志，但线程本身不会停止。只有让线程在执行过程中感知中断（检查标志或处理中断异常），才能实现终止。

补充说明 #

如果使用NIO进行网络操作，中断线程会触发Channel关闭，同样能终止网络任务。所有标准Java阻塞IO操作都会响应线程中断并抛出对应异常，只需在捕获异常后终止线程即可。

内容的提问来源于stack exchange，提问作者coderodde