当前位置：首页 > Java

java如何让线程停止

2026-02-04 13:55:07Java

停止线程的方法

在Java中，线程的停止可以通过以下几种方式实现，每种方式有不同的适用场景和注意事项。

使用标志位控制线程退出

通过设置一个共享的volatile变量作为标志位，线程在运行时检查该标志位，决定是否继续执行。

public class StoppableThread implements Runnable {
    private volatile boolean running = true;

    public void stop() {
        running = false;
    }

    @Override
    public void run() {
        while (running) {
            // 执行任务逻辑
            System.out.println("Thread is running...");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                System.out.println("Thread interrupted");
                break;
            }
        }
        System.out.println("Thread stopped");
    }
}

调用stop()方法可以安全地终止线程，避免直接使用Thread.stop()导致的资源未释放问题。

使用`Thread.interrupt()`方法

interrupt()方法会设置线程的中断标志，线程可以通过检查Thread.interrupted()或isInterrupted()来决定是否退出。

public class InterruptibleThread implements Runnable {
    @Override
    public void run() {
        while (!Thread.currentThread().isInterrupted()) {
            try {
                System.out.println("Thread is running...");
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                System.out.println("Thread interrupted");
                Thread.currentThread().interrupt(); // 重新设置中断状态
                break;
            }
        }
        System.out.println("Thread stopped");
    }
}

调用thread.interrupt()后，线程会在下一次检查中断状态时退出。

使用`ExecutorService`关闭线程池

如果使用线程池管理线程，可以通过shutdown()或shutdownNow()方法停止所有线程。

ExecutorService executor = Executors.newFixedThreadPool(2);
executor.submit(() -> {
    while (!Thread.currentThread().isInterrupted()) {
        System.out.println("Task running...");
    }
});
executor.shutdownNow(); // 强制终止所有任务

shutdownNow()会尝试中断所有正在运行的线程，而shutdown()会等待任务完成。