如何优雅终止基于控制台的多线程程序？附线程类代码

嗨，这个场景我太熟了——控制台跑多线程后台任务，既要能正常退出，又不能粗暴杀线程导致资源没清理。给你几个我平时常用的优雅方案，一步步来：

你已经想到要把while(true)改成布尔变量，这里关键是要给变量加volatile修饰，保证所有线程都能及时看到这个变量的变化（不然线程可能缓存旧值，一直停不下来）。

修改你的MyClass代码：

public class MyClass implements Runnable {
    private volatile Device device = null;
    private volatile boolean running = true; // 终止标志位

    public MyClass(Device device) {
        this.device = device;
    }

    // 对外暴露关闭方法
    public void shutdown() {
        this.running = false;
    }

    @Override
    public void run() {
        while (running) { // 用标志位代替true
            try {
                Worker worker = new Worker();
                worker.work();
                System.out.println("Waiting 6 seconds!");
                Thread.sleep(6 * 1000);
                System.out.println("------------------------------------");
            } catch (InterruptedException e) {
                // 如果遇到中断，也直接终止循环
                Thread.currentThread().interrupt();
                break;
            } catch (Exception e) {
                // 处理其他异常，比如日志打印
                e.printStackTrace();
            }
        }
        // 这里可以加资源清理逻辑，比如关闭device
        if (device != null) {
            device.close();
        }
        System.out.println("线程已优雅退出");
    }
}

然后在主线程里，你需要：

1. 保存所有MyClass实例和对应的线程
2. 监听控制台输入，比如输入exit时触发关闭：

public static void main(String[] args) {
    List<MyClass> workerList = new ArrayList<>();
    List<Thread> threadList = new ArrayList<>();

    // 启动10个线程
    for (int i = 0; i < 10; i++) {
        Device device = new Device(); // 假设你的Device实例
        MyClass worker = new MyClass(device);
        workerList.add(worker);
        Thread thread = new Thread(worker);
        threadList.add(thread);
        thread.start();
    }

    // 监听控制台输入，触发关闭
    Scanner scanner = new Scanner(System.in);
    while (scanner.hasNextLine()) {
        String input = scanner.nextLine();
        if ("exit".equalsIgnoreCase(input)) {
            System.out.println("收到退出指令，正在关闭所有线程...");
            // 通知所有线程终止
            for (MyClass worker : workerList) {
                worker.shutdown();
            }
            // 等待所有线程结束
            for (Thread thread : threadList) {
                try {
                    thread.join();
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            }
            System.out.println("所有线程已关闭，程序退出");
            scanner.close();
            break;
        }
    }
}

Java的线程中断不是强制杀死线程，而是给线程发一个“要终止”的信号，线程自己决定怎么处理。这种方式适合线程里有阻塞操作（比如sleep、wait）的场景，因为这些阻塞方法会响应中断并抛出InterruptedException。

修改MyClass的run方法：

@Override
public void run() {
    while (!Thread.currentThread().isInterrupted()) { // 检查线程是否被中断
        try {
            Worker worker = new Worker();
            worker.work();
            System.out.println("Waiting 6 seconds!");
            Thread.sleep(6 * 1000);
            System.out.println("------------------------------------");
        } catch (InterruptedException e) {
            // 非常重要：恢复中断标志，让上层代码能感知到中断
            Thread.currentThread().interrupt();
            // 跳出循环，终止线程
            break;
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    // 资源清理
    if (device != null) {
        device.close();
    }
    System.out.println("线程已优雅退出");
}

主线程里触发关闭的逻辑变成：

// 当收到exit指令时
for (Thread thread : threadList) {
    thread.interrupt(); // 给每个线程发中断信号
}
// 然后等待线程结束
for (Thread thread : threadList) {
    try {
        thread.join();
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
}

如果用户直接按Ctrl+C关闭控制台，上面的方案可能来不及清理资源。这时候可以给JVM注册一个Shutdown Hook，JVM退出前会自动执行这个钩子线程，帮我们优雅关闭所有线程。

在主线程里添加：

Runtime.getRuntime().addShutdownHook(new Thread(() -> {
    System.out.println("\n检测到程序终止，正在优雅关闭线程...");
    // 这里可以用方案1的shutdown，或者方案2的interrupt
    for (MyClass worker : workerList) {
        worker.shutdown();
    }
    for (Thread thread : threadList) {
        try {
            thread.join(5000); // 最多等5秒，避免无限等待
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
    System.out.println("所有线程已关闭");
}));

几个关键注意点： #

• 绝对不要用Thread.stop()方法！它会直接终止线程，导致资源泄漏、数据不一致，已经被废弃了。
• 不管用哪种方案，一定要在线程退出前清理资源（比如关闭Device、释放连接等）。
• 如果你的worker.work()里有长时间阻塞的操作（比如IO、网络请求），要确保这些操作能响应中断或者检查终止标志，不然线程可能停不下来。

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