Java의 스레드 중단에 대한 자세한 소개

이 글은 java에 대한 관련 지식을 제공하며, 스레드 중단에 대한 관련 내용을 주로 소개합니다. 중단이란 두 개의 스레드 a와 b와 같이 스레드 사이에서 서로를 중단시키는 방법입니다. a가 b의 실행을 중단하려는 경우 어떤 순간에는 b.interrupt() 메소드를 호출하여 인터럽트할 수 있습니다. 모두에게 도움이 되기를 바랍니다.

추천 학습: "java 비디오 튜토리얼"

Java의 스레드 중단

1 스레드 중단 관련 방법 소개

Java 멀티 스레드 프로그래밍의 interrupt() 메서드, isInterrupted() 메서드와 interrupted() 메서드는 모두 스레드 중단과 관련된 메서드이며 매우 중요합니다. 이 세 가지 방법의 이름은 매우 유사하며, 원리를 이해하지 못하면 혼동하기 쉽습니다. 여기서는 이를 구별하기 위해 소개합니다. interrupt() 메서드와 isInterrupted() 메서드는 모두 인스턴스 메서드(클래스의 정적 메서드가 아님)이므로 앞에 thread1을 추가했습니다. code>, 인스턴스화된 특정 스레드를 나타냄: <code>interrupt()方法、isInterrupted()方法和interrupted()方法都是跟线程中断相关的方法，都非常重要。这三个方法名称非常相似，不理解原理时容易混淆，这里分别介绍下，以加以区分。由于interrupt()方法和isInterrupted()方法都是实例方法(非类上的静态方法)，因此我在前面加了个thread1，表示一个实例化的具体线程：

thread1.interrupt()方法

thread1.interrupt()方法用来中断线程，所谓的中断，大家可以通俗的理解为打断。比如有两个线程a和b，当线程a因为某些原因想打断线程b时，a线程内部可以调用b.interrupt()。不过要注意，实现上是通过设置线程b的中断状态标记实现的。b线程代码运行期间，可以在一个循环体内不断的判断该中断状态标记，以确认是否真正响应a的中断请求(比如退出执行等等)。

thread1.isInterrupted()方法

thread1.isInterrupted()方法用来获取一个线程的中断状态。比如有两个线程a和b，当线程a因为某些原因想打断线程b时，可以通过b.interrupt()对b进行中断。在线程b内部，可以判断自己的中断状态，是否是被中断的，然后根据中断状态确认是否响应中断请求(比如退出当前线程的循环体等等)。thread1.isInterrupted()方法内部直接调用了native方法，传入的ClearInterrupted参数是false，表示不清空中断状态标记：

public boolean isInterrupted() {
  return isInterrupted(false);
}// ClearInterrupted表示是否清楚中断状态标记private native boolean isInterrupted(boolean ClearInterrupted);

因此调用完该方法后，中断标志位不清除。

Thread.interrupted()方法

Thread.interrupted()是定义在Thread类上的静态方法，用来判断当前线程的中断状态，跟thread1.isInterrupted()不同的是，该方法返回中断状态之后，会复位(reset)中断状态标记，所谓的复位即恢复默认状态，也可以说是清空中断状态标记。看Thread类源码可以看到Thread.interrupted()方法实现非常简单，内部直接调用了native方法，只不过ClearInterrupted参数传的是true，表示清空中断状态标记：

public static boolean interrupted() {
  return currentThread().isInterrupted(true);
}// ClearInterrupted表示是否清楚中断状态标记private native boolean isInterrupted(boolean ClearInterrupted);

可以看出thread1.isInterrupted()和Thread.interrupted()的区别其实就在于获取完中断状态标记之后，是否复位。大家可以根据需要进行选择使用。

2 不考虑线程阻塞时如何优雅的停止一个线程

要想优雅的停止某个线程的运行，需要前面介绍的中断机制。比如两个线程a和b，当线程a想中断线程b时，可以通过调用b.interrupt()方法，来设置线程b的中断标记，以达到通知线程b的目的。而线程b需要不断的检查自己的中断标记，以随时响应其他线程的中断，比如下面的实现所示：

public class TestMain {
    public static void main(String[] args) throws InterruptedException {
        Thread b = new Thread(new Runnable() {
            @Override
            public void run() {
                int num = 0;
                while(true) {
                    if (Thread.interrupted()) {
                        break;
                    }
                    System.out.println("thread b running, num is:" + num++);
                }
            }
        });
        b.start();
        // 主线程sleep 1ms，让线程b循环一小会
        Thread.sleep(1);
        // 中断线程b
        b.interrupt();
    }
}

这里在主线程内新创建了一个线程b，线程b内部是一个循环体，每次循环开始都检查一下中断状态，确认是否被中断，如果被中断了即退出循环，结束线程的执行。主线程sleep了1ms，让线程b先循环几次。接着主线程通过b.interrupt()对线程b

thread1.interrupt() 메서드

thread1.interrupt( ) 메소드는 스레드를 인터럽트하는 데 사용됩니다. 소위 인터럽트는 일반적으로 인터럽트로 이해될 수 있습니다. 예를 들어 a 스레드와 b라는 두 개의 스레드가 있습니다. 스레드 a가 어떤 이유로 스레드 b를 중단하려고 할 때입니다. , , b.interrupt()는 a 스레드 내에서 호출할 수 있습니다. 그러나 스레드 b의 인터럽트 상태 플래그를 설정하여 구현이 수행된다는 점에 유의하세요. b 스레드 코드가 실행되는 동안 인터럽트 상태 플래그는 루프 본문에서 지속적으로 판단되어 의 인터럽트 요청에 실제로 응답하는지 확인할 수 있습니다. a (예: 실행 종료 등). 🎜

thread1.isInterrupted() 메서드

🎜thread1.isInterrupted() 메서드는 값을 얻는 데 사용됩니다. 스레드 인터럽트 상태. 예를 들어 a 스레드와 b라는 두 개의 스레드가 있습니다. 스레드 a가 어떤 이유로 스레드 b를 중단하려고 할 때입니다. , , b.interrupt()를 통해 b를 중단할 수 있습니다. b 스레드 내에서 인터럽트 상태와 인터럽트 여부를 확인한 다음, 인터럽트 상태에 따라 인터럽트 요청에 응답할지 여부를 확인할 수 있습니다(예: 현재 스레드의 루프 본문 종료, 등.). thread1.isInterrupted() 메서드는 native 메서드를 직접 호출하고 전달된 ClearInterrupted 매개변수는 false입니다. 이는 인터럽트 상태 플래그를 지우지 않음을 의미합니다. 🎜

thread b running, num is:0thread b running, num is:1thread b running, num is:2...
thread b running, num is:25thread b running, num is:26thread b running, num is:27Process finished with exit code 0

🎜따라서 이 메서드를 호출한 후에는 인터럽트 플래그 비트가 지워지지 않습니다. 🎜

Thread.interrupted() 메서드

🎜Thread.interrupted()는 Thread에 정의되어 있습니다. 클래스의 정적 메서드는 현재 스레드의 중단 상태를 확인하는 데 사용됩니다. thread1.isInterrupted()와의 차이점은 이 메서드가 다음을 반환한다는 것입니다. 인터럽트 상태, 인터럽트 상태 표시는 리셋(리셋)됩니다. 소위 재설정은 기본 상태를 복원하는 것이며 인터럽트 상태 표시를 지우는 것이라고 할 수도 있습니다. Thread 클래스 소스 코드를 보면 Thread.interrupted() 메서드의 구현이 매우 간단하다는 것을 알 수 있습니다. 내부적으로 직접 호출되지만 ClearInterrupted 매개변수가 true를 전달합니다. 이는 인터럽트 상태 표시가 지워지는 것을 의미합니다. 🎜

public class TestMain {
    public static void main(String[] args) throws InterruptedException {
        Thread b = new Thread(new Runnable() {
            @Override
            public void run() {
                int num = 0;
                while(true) {
                    if (Thread.interrupted()) {
                        break;
                    }
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        // Thread.currentThread().interrupt();
                        e.printStackTrace();
                    }
                    System.out.println("thread b running, num is:" + num++);
                }
            }
        });
        b.start();
        // 主线程sleep5.5秒，让线程b循环5次
        Thread.sleep(5500);
        // 中断线程b
        b.interrupt();
    }
}

🎜thread1.isInterrupted를 볼 수 있습니다. () 및 Thread .interrupted()의 차이점은 실제로 인터럽트 상태 표시를 얻은 후 재설정할지 여부에 있습니다. 필요에 따라 선택하여 사용하실 수 있습니다. 🎜

2 스레드 차단을 고려하지 않고 스레드를 정상적으로 중지하는 방법🎜🎜스레드 실행을 정상적으로 중지하려면 앞서 소개한 인터럽트 메커니즘이 필요합니다. 예를 들어, a와 b라는 두 개의 스레드가 있습니다. a 스레드가 b 스레드를 중단하려고 하면 다음과 같이 할 수 있습니다. call >b.interrupt() 메소드는 b 스레드의 인터럽트 플래그를 설정하여 b 스레드에 알리는 데 사용됩니다. 스레드 b는 다음 구현에서 볼 수 있듯이 언제든지 다른 스레드의 인터럽트에 응답하기 위해 자체 인터럽트 표시를 지속적으로 확인해야 합니다. 🎜

thread b running, num is:0thread b running, num is:1thread b running, num is:2thread b running, num is:3thread b running, num is:4java.lang.InterruptedException: sleep interrupted
  at java.lang.Thread.sleep(Native Method)
  at test.TestMain.run(TestMain.java:25)
  at java.lang.Thread.run(Thread.java:748)
thread b running, num is:5thread b running, num is:6thread b running, num is:7thread b running, num is:8thread b running, num is:9...

🎜여기는 메인 스레드의 새로운 기능입니다. > b 스레드가 생성됩니다. b 스레드 내부에는 루프 본문이 있으며, 각 루프가 시작될 때 인터럽트 상태가 중단되었는지 확인합니다. 중단되면 루프를 종료하고 스레드 실행을 종료합니다. 메인 스레드는 1ms 동안 휴면 상태를 유지하고 먼저 스레드 b가 여러 번 루프되도록 합니다. 그런 다음 메인 스레드는 b.interrupt()를 통해 스레드 b를 중단합니다. 프로그램을 실행하면 다음과 같은 출력을 볼 수 있습니다(결과는 기계마다 다름). 🎜

thread b running, num is:0thread b running, num is:1thread b running, num is:2...
thread b running, num is:25thread b running, num is:26thread b running, num is:27Process finished with exit code 0

可以看到主线程成功的中断了线程b。当然，主线程之所以能成功的中断线程b，是因为线程b一直在检查自己的中断状态(如果线程b太自我，不考虑其他线程，只考虑自己运行，那主线程就无法成功打断线程b了)。

3 考虑线程阻塞时如何优雅的停止一个线程

前面我们成功的在主线程中中断了线程b，然后如果线程b中存在阻塞，比如下面的代码所示，线程b在sleep时被主线程中断：

public class TestMain {
    public static void main(String[] args) throws InterruptedException {
        Thread b = new Thread(new Runnable() {
            @Override
            public void run() {
                int num = 0;
                while(true) {
                    if (Thread.interrupted()) {
                        break;
                    }
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        // Thread.currentThread().interrupt();
                        e.printStackTrace();
                    }
                    System.out.println("thread b running, num is:" + num++);
                }
            }
        });
        b.start();
        // 主线程sleep5.5秒，让线程b循环5次
        Thread.sleep(5500);
        // 中断线程b
        b.interrupt();
    }
}

这时线程b会抛出InterruptedException异常，上面的代码中我们仅仅打印了下该异常，相当于什么都没做。运行该代码结果如下：

thread b running, num is:0thread b running, num is:1thread b running, num is:2thread b running, num is:3thread b running, num is:4java.lang.InterruptedException: sleep interrupted
  at java.lang.Thread.sleep(Native Method)
  at test.TestMain$1.run(TestMain.java:25)
  at java.lang.Thread.run(Thread.java:748)
thread b running, num is:5thread b running, num is:6thread b running, num is:7thread b running, num is:8thread b running, num is:9...

可以看出，主线程未能成功中断线程b。

3.1 InterruptedException异常介绍

线程内调用wait，join，sleep时都会进入阻塞状态。当线程处于阻塞状态时被中断，这时线程就会抛出InterruptedException异常，其实大家可以通俗的理解为一种通知即可。以sleep方法为例，大家可以按如下模拟实现来理解(底层是native实现)：

public static void sleep(long millis) throws InterruptedException 
{
    while (/* still waiting for millis to become zero */) 
    {
        if (Thread.interrupted())
        {
            throw new InterruptedException();
        }
        // Keep waiting
    }
}

有了InterruptedException异常通知，线程就可以在阻塞时立即知道被中断了，进而采取一定的措施响应中断。需要注意的一点是，由于抛出了InterruptedException异常，因此不会在设置中断标志位。

3.2 考虑线程阻塞时如何优雅的停止一个线程

理解了InterruptedException异常，我们就可以在线程即使发生阻塞时也能成功进行中断了，如下所示：

public class TestMain {
    public static void main(String[] args) throws InterruptedException {
        Thread b = new Thread(new Runnable() {
            @Override
            public void run() {
                int num = 0;
                while(true) {
                    if (Thread.interrupted()) {
                        break;
                    }
                    try {
                        Thread.sleep(1000); // 用sleep来模拟线程的执行
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt(); // 注意这里是重点！
                    }
                    System.out.println("thread b running, num is:" + num++);
                }
            }
        });
        b.start();
        // 主线程sleep5.5秒，让线程b先循环5次
        Thread.sleep(5500);
        // 中断线程b
        b.interrupt();
    }
}

这里我们在检查到InterruptedException异常时，重新设置了中断标志位，这样下次循环一开始时，即可判断被中断了，进而退出循环体。当然我们可以在InterruptedException异常catch时直接退出。

4 总结

我们介绍了Java中的线程中断相关知识点，通俗来讲，大家可以理解为中断就是一种线程间相互打断的一种方式，比如两个线程a和b，a如果在某一时刻想打断b的执行，则可以调用b.interrupt()方法进行中断，但是要注意，这里仅仅是设置b的中断状态位，b看到中断状态位后可以自行决定是否响应，当然，正常情况我们写的代码都需要做好中断状态位的判断(这一点大家在写业务代码时确实经常忽略)。另外对于阻塞中的线程，Java通过InterruptedException异常来进行通知。

推荐学习：《java视频教程》

위 내용은 Java의 스레드 중단에 대한 자세한 소개의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!