深入理解高并发编程 - Thread 类的 stop () 和 interrupt ()

缺乏、安全感 2023-10-15 10:34 12阅读 0赞

## stop() ##

stop() 方法被用于停止线程。然而，需要注意的是，stop() 方法已经被标记为已废弃（deprecated），并且不推荐使用。这是因为使用该方法可能导致不可预料的问题和数据不一致性，因此它被认为是不安全的。

当调用 stop() 方法来终止一个线程时，它会立即停止线程的执行，无论线程是否在一个安全的状态下。这可能导致线程被终止时，它正在执行一些重要的操作，如写入文件、更新数据等，导致数据损坏或不一致。

如果线程持有 ReentrantLock 锁，被 stop()的线程并不会自动调用 ReentrantLock 的 unlock()去释放锁，那其他线程就再也没机会获得 ReentrantLock 锁， 这样其他线程就再也不能执行 ReentrantLock 锁锁住的代码逻辑。 所以该方法就不建议使用了， 类似的方法还有 suspend()和resume()方法。

public class UnsafeStopExample {
    
        public static void main(String[] args) throws InterruptedException {
            Thread thread = new Thread(() -> {
                while (true) {
                    System.out.println("Thread is running...");
                }
            });
    
            thread.start();
            Thread.sleep(1000); // 让线程运行一会儿
    
            thread.stop(); // 使用不安全的 stop() 方法终止线程
        }
    }

在这个例子中，线程在一个无限循环内部执行，打印一条消息。主线程启动了这个线程，然后经过一秒后，使用 stop() 方法终止了它。这看起来似乎没有问题，但实际上，这个方法存在潜在的风险。

当调用 stop() 方法终止线程时，线程可能会在任何地方被停止，甚至可能在一条语句的中间。这可能导致线程被终止时，它正在进行一些重要的操作，如更新数据、释放资源等。这可能会使系统处于不一致的状态。

此外，如果线程在使用锁、I/O 操作或其他资源时被 stop() 终止，这些资源可能会被线程占用，而没有正确释放，从而导致资源泄漏。

综上所述，stop() 方法的使用是不安全的，因为它可能在不可预测的时刻终止线程，从而导致数据损坏、资源泄漏以及系统不一致的情况。因此，推荐使用其他更安全和可控的方法来终止线程，比如让线程自己处理中断请求。

## interrupt () ##

interrupt() 方法是用于中断线程的方法。它并不会直接终止线程，而是向目标线程发送一个中断请求，然后由目标线程自行处理中断。这样做的好处是可以更安全地终止线程，允许线程在适当的时机进行清理操作。

当调用一个线程的 interrupt() 方法时，有两种可能的情况：

如果线程处于阻塞状态（如调用了 sleep()、wait()、join() 等方法），那么它将收到一个 InterruptedException 异常，并且中断状态会被清除（即调用 isInterrupted() 会返回 false）。
    
    如果线程没有被阻塞，中断状态会被设置（即调用 isInterrupted() 会返回 true），线程可以在合适的时机检查中断状态，并根据情况决定是否继续执行。

当一个线程调用 interrupt() 方法时，它实际上是向目标线程发送一个中断请求，目标线程可以根据中断状态来决定如何处理这个请求。下面是一个使用 interrupt() 方法的示例，说明为什么它是一种更安全的线程终止方式：

public class InterruptExample {
    
        public static void main(String[] args) throws InterruptedException {
            Thread thread = new Thread(() -> {
                while (!Thread.currentThread().isInterrupted()) {
                    System.out.println("Thread is running...");
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt(); // 重新设置中断状态
                        System.out.println("Thread interrupted while sleeping.");
                    }
                }
            });
    
            thread.start();
            Thread.sleep(5000); // 让线程运行一会儿
    
            thread.interrupt(); // 使用 interrupt() 方法请求中断线程
        }
    }

在这个示例中，线程在一个循环内部执行，并在每次循环中检查中断状态。如果中断状态被设置（通过调用 interrupt() 方法），则线程会在适当的时机停止循环并退出线程。

另外，注意到在线程内部的 try-catch 块中，当线程在执行 Thread.sleep() 时，如果被中断，会捕获 InterruptedException 异常。在这里，我们重新设置了线程的中断状态，以便在后续的循环迭代中，线程可以检查中断状态并正确地终止。

这种使用 interrupt() 方法的方式更安全，因为它遵循了线程自行决定是否终止的原则，同时也可以保证在终止前进行清理操作（例如，释放锁、关闭资源等）。相对于直接调用 stop() 方法，这种方式更适合处理线程的安全终止。