如何停止线程？

在 Java 中，停止线程需要谨慎处理，因为直接中断线程可能会导致资源泄露或数据不一致等问题。Java 不鼓励使用 Thread.stop() 方法，因为该方法已被废弃，且在 Java 9 及以后的版本中已被删除。下面是几种推荐的方式来停止线程：

1. 使用标志变量

这是最常见和最安全的方式之一。通过设置一个共享的布尔变量来指示线程何时停止运行。

示例代码

public class StopThreadExample {
   

    private volatile boolean stopRequested = false;

    public void requestStop() {
   
        stopRequested = true;
    }

    public void runTask() {
   
        while (!stopRequested) {
   
            // 执行任务...
            System.out.println("Task is running...");

            try {
   
                // 线程休眠，防止 CPU 占用过高
                Thread.sleep(1000);
            } catch (InterruptedException e) {
   
                // 如果线程被中断，捕获异常
                Thread.currentThread().interrupt();
                return; // 返回以结束线程
            }
        }
    }

    public static void main(String[] args) throws InterruptedException {
   
        StopThreadExample example = new StopThreadExample();

        Thread thread = new Thread(example::runTask);
        thread.start();

        // 等待一段时间后请求线程停止
        Thread.sleep(5000); // 等待 5 秒
        example.requestStop();

        // 等待线程终止
        thread.join();
    }
}

2. 使用 Interrupt 机制

通过调用 Thread.interrupt() 方法来中断线程。线程可以监听 InterruptedException 或检查 Thread.isInterrupted() 方法来判断是否被中断。

示例代码

public class InterruptThreadExample {
   

    public void runTask() throws InterruptedException {
   
        while (!Thread.currentThread().isInterrupted()) {
   
            // 执行任务...
            System.out.println("Task is running...");

            // 线程休眠，防止 CPU 占用过高
            Thread.sleep(1000);
        }
    }

    public static void main(String[] args) throws InterruptedException {
   
        InterruptThreadExample example = new InterruptThreadExample();

        Thread thread = new Thread(example::runTask);
        thread.start();

        // 等待一段时间后请求线程停止
        Thread.sleep(5000); // 等待 5 秒
        thread.interrupt(); // 请求中断线程

        // 等待线程终止
        thread.join();
    }
}

3. 使用 ExecutorService 和 Future

如果你使用了线程池，可以使用 ExecutorService 和 Future 来停止线程。

示例代码

import java.util.concurrent.*;

public class ExecutorServiceExample {
   

    public static void main(String[] args) throws ExecutionException, InterruptedException {
   
        ExecutorService executor = Executors.newSingleThreadExecutor();

        Future<?> future = executor.submit(() -> {
   
            while (true) {
   
                // 执行任务...
                System.out.println("Task is running...");

                try {
   
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
   
                    Thread.currentThread().interrupt();
                    break; // 结束线程
                }
            }
        });

        // 等待一段时间后请求线程停止
        Thread.sleep(5000); // 等待 5 秒
        future.cancel(true); // 请求取消任务

        // 关闭线程池
        executor.shutdown();
    }
}

注意事项

• 避免使用 Thread.stop()：该方法已被废弃，并可能导致程序崩溃或资源泄漏。
• 正确处理中断异常：在捕获 InterruptedException 后应重新设置中断标志。
• 优雅地结束线程：尽量让线程在完成当前的工作周期后结束，而不是立即中断。

通过上述方法，你可以安全地停止 Java 中的线程。