Thread的stop和interrupt的区别

关忆北.

发布于 2024-06-02 09:03:24

830

发布于 2024-06-02 09:03:24

文章被收录于专栏：关忆北.关忆北.

Thread.stop

Thread.stop()方法已被废弃。

因为本质上它是不安全的，使用该方法可能会导致数据、资源不一致的问题，

public class ThreadDemo {
    static class MyThread extends Thread {
        @Override
        public void run() {
            while (true) {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    // 当线程被中断时，这里会捕获 InterruptedException 但注意，我们不会使用它来处理停止逻辑，而是直接使用 stop() 在实际中，你应该检查中断状态并适当地响应
                }
                // 假设这里有一些其他代码...
            }
        }
    }
    public static void main(String[] args) {
        MyThread myThread = new MyThread();
        myThread.start();
        //等待一段时间以便线程可以开始运行
        try {
            Thread.sleep(2000);
        } catch (Exception e) {
            e.printStackTrace();
        }
        // 使用 stop() 停止线程（不推荐！）这会导致线程在任意位置停止，可能会留下不一致的状态
        myThread.stop();
        System.out.println("Thread has been stopped (using deprecated stop method).");
    }
}

Thread.stop测试结果

在控制台可以看到输出：Thread has been stopped (using deprecated stop method).可以明确看到：stop方法已被废弃。

Thread interrupt

使用stop方法会导致线程突然终止，可能导致如：线程持有的资源没有被正确释放，使得程序状态不一致问题。因此建议使用更安全的方式来停止线程，比如使用interrupt发出终端请求来实现停止一个正在运行的线程。

/**
 * @author: liu_pc
 * Date:        2024/5/6
 * Description: 安全的停止一个线程
 * Version:     1.0
 */
@Slf4j
public class InterruptThreadExample {
    static class MyThread extends Thread {
        public void run() {
            while (!Thread.currentThread().isInterrupted()) {
                // 模拟一些长时间运行的任务
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    // 当线程被中断时，这里会捕获 InterruptedException
                    // 并且设置中断状态为 true，以便在外部检查
                    Thread.currentThread().interrupt(); // 保留中断状态以供外部检查
                    break; // 退出循环，线程将安全地结束
                }
                // 假设这里有一些其他代码...
            }
        }
    }

    public static void main(String[] args) throws InterruptedException {
        MyThread myThread = new MyThread();
        myThread.start();

        // 等待一段时间以便线程可以开始运行
        Thread.sleep(2000);

        // 使用 interrupt() 方法中断线程
        myThread.interrupt();

        // 等待线程结束
        myThread.join();

        System.out.println("Thread has been stopped gracefully using interruption.");
    }
}