当前位置：首页 > Java

java如何终止线程

2026-03-03 07:56:02Java

终止线程的方法

在Java中，终止线程需要谨慎处理，直接使用Thread.stop()方法已被废弃，因为它可能导致资源未释放或数据不一致。以下是几种安全终止线程的方法：

使用标志位控制线程退出

通过设置一个标志位，让线程在运行时检查该标志位，从而安全退出。这种方法不会强制终止线程，而是让线程自然结束。

public class MyThread extends Thread {
    private volatile boolean running = true;

    public void stopRunning() {
        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 was interrupted");
            }
        }
        System.out.println("Thread stopped safely");
    }
}

// 使用示例
MyThread thread = new MyThread();
thread.start();
// 终止线程
thread.stopRunning();

使用`Thread.interrupt()`方法

interrupt()方法会设置线程的中断标志位，线程可以通过检查中断状态或捕获InterruptedException来安全退出。

public class MyThread extends Thread {
    @Override
    public void run() {
        while (!Thread.currentThread().isInterrupted()) {
            // 线程执行的代码
            System.out.println("Thread is running...");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // 捕获中断异常后，重新设置中断标志位
                Thread.currentThread().interrupt();
                System.out.println("Thread was interrupted");
            }
        }
        System.out.println("Thread stopped safely");
    }
}

// 使用示例
MyThread thread = new MyThread();
thread.start();
// 终止线程
thread.interrupt();

使用`ExecutorService`管理线程

通过ExecutorService可以更优雅地管理线程的生命周期，调用shutdown()或shutdownNow()方法终止线程池中的线程。

ExecutorService executor = Executors.newSingleThreadExecutor();
executor.submit(() -> {
    while (!Thread.currentThread().isInterrupted()) {
        System.out.println("Thread is running...");
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            System.out.println("Thread was interrupted");
        }
    }
});

// 终止线程池
executor.shutdownNow();