如何正确的停掉线程?

Love The Way You Lie 2023-10-11 23:46 12阅读 0赞

在Java中，停止线程的正确方法通常是使用协作方式，而不是强制性地终止线程。强制性终止线程可能会导致资源泄漏或数据不一致等问题。下面是一个演示如何正确停止线程的代码示例：

public class MyThread implements Runnable {
        private volatile boolean running = true;
    
        public void stopThread() {
            running = false;
        }
    
        @Override
        public void run() {
            while (running) {
                // 线程的业务逻辑
            }
        }
    }

在上面的代码中，MyThread类实现了Runnable接口，并包含一个running标志，用于控制线程是否继续执行。stopThread方法被调用时，它将将running标志设置为false，从而终止线程。

接下来我们再看一个使用上述线程类的示例：

public class Main {
        public static void main(String[] args) {
            MyThread myThread = new MyThread();
            Thread thread = new Thread(myThread);
            thread.start();
    
            // 停止线程的逻辑
            try {
                Thread.sleep(1000); // 假设等待1秒
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
    
            myThread.stopThread(); // 停止线程
    
            // 等待线程结束
            try {
                thread.join();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
    
            System.out.println("线程已停止");
        }
    }

在上述示例中，我们创建了一个MyThread实例，并将其传递给Thread构造函数来创建一个新的线程。然后，我们调用myThread.stopThread()方法停止线程。为了确保线程已经停止，我们使用thread.join()方法等待线程结束。

请注意，running标志被声明为volatile，这是为了确保线程之间的可见性。这样做可以确保线程在检查 running标志时能够看到最新的值。