线程可以通过调用要中断的线程的 Thread 对象上的中断来向 JVM 发送中断信号以进行中断。这意味着线程的中断是由任何其他线程调用interrupt()方法引起的。

Thread类提供了三种中断方法

  • void Interrupt() - 中断线程。

  • static boolean Interrupted() - 测试当前线程是否已被中断。

  • boolean isInterrupted() - 测试线程是否已被中断。

示例 1

在此示例中，我们正在创建一个 Task 对象，它实现了 Runnable 接口来充当线程。使用 start() 方法，我们启动了线程。作为下一条语句，我们使用 Interrupt() 方法中断线程，并在 run() 方法中打印线程属性。

package com.yxjc123;

public class TestThread {
   public static void main(String[] args) {
      System.out.println("Thread main started");
      final Task task = new Task();
      final Thread thread = new Thread(task);
      thread.start();
      thread.interrupt(); // 调用interrupt()方法
      System.out.println("Main Thread finished");
   }
}
class Task implements Runnable {
   @Override
   public void run() {
      for (int i = 0; i < 5; i++) {
         System.out.println("[" + Thread.currentThread().getName() + "] Message " + i);
         if(Thread.interrupted()) {
            System.out.println("This thread was interruped by someone calling this Thread.interrupt()");
            System.out.println("Cancelling task running in thread " + Thread.currentThread().getName());
            System.out.println("After Thread.interrupted() call, JVM reset the interrupted value to: " + Thread.interrupted());
            break;
         }
      }
   }
}

输出

Thread main started
Main Thread finished
[Thread-0] Message 0
This thread was interruped by someone calling this Thread.interrupt()
Cancelling task running in thread Thread-0
After Thread.interrupted() call, JVM reset the interrupted value to: false

示例 2

在此示例中，我们正在处理中断并继续线程。我们正在创建一个 Task 对象，它实现了 Runnable 接口来充当线程。使用 start() 方法，我们启动了线程。作为下一条语句，我们使用 Interrupt() 方法中断线程，并在 run() 方法中处理 InterruptedException 并打印详细信息。

package com.yxjc123;

public class TestThread {
   public static void main(String[] args) {
      System.out.println("Thread main started");
      final Task task = new Task();
      final Thread thread = new Thread(task);
      thread.start();
      thread.interrupt(); //调用interrupt()方法
      System.out.println("Main Thread finished");
   }
}
class Task implements Runnable {
   @Override
   public void run() {
      for (int i = 0; i < 5; i++) {
         System.out.println("[" + Thread.currentThread().getName() + "] Message " + i);
         try {
			Thread.sleep(50);
		} catch (InterruptedException e) {
			System.out.println("This thread was interruped by someone calling this Thread.interrupt()");
		}        
      }
   }
}

输出

Thread main started
Main Thread finished
[Thread-0] Message 0
This thread was interruped by someone calling this Thread.interrupt()
[Thread-0] Message 1
[Thread-0] Message 2
[Thread-0] Message 3
[Thread-0] Message 4

示例 3

在这个例子中，我们展示了多个线程并使用interrupted()方法来检查线程是否被中断。我们正在创建多个实现 Runnable 接口的 Task 对象来充当线程。使用 start() 方法，我们启动了线程。然后，我们使用interrupt()方法中断线程，并在run()方法中使用interrupted，打印详细信息。

package com.yxjc123;

public class TestThread {
   public static void main(String[] args) {
      System.out.println("Thread main started");
      final Task task1 = new Task();
      final Thread thread1 = new Thread(task1);
      final Task task2 = new Task();
      final Thread thread2 = new Thread(task2);
      final Task task3 = new Task();
      final Thread thread3 = new Thread(task3);
      thread1.start();
      thread2.start();
      thread3.start();
      thread1.interrupt(); //调用interrupt()方法
      System.out.println("Main Thread finished");
   }
}
class Task implements Runnable {
   @Override
   public void run() {
      if(Thread.interrupted()) {
         System.out.println("[" + Thread.currentThread().getName() + "] Interrupted ");
      }else {
         System.out.println("[" + Thread.currentThread().getName() + "] Uninterrupted ");
      }
   }
}

输出

Thread main started
Main Thread finished
[Thread-2] Uninterrupted 
[Thread-0] Interrupted 
[Thread-1] Uninterrupted