Java 线程中断如何处理

在 Java 中，线程中断是一种协作机制，允许一个线程通知另一个线程某个特定条件已经发生，以便被通知的线程可以采取相应的行动。处理线程中断时，需要注意以下几点：

1. 检查中断状态： 在执行任务之前，可以使用 Thread.interrupted() 或 Thread.isInterrupted() 方法检查当前线程是否已经被中断。Thread.interrupted() 会清除中断状态，而 Thread.isInterrupted() 不会清除中断状态。

   if (Thread.interrupted()) {
       // 处理中断
   }
   

2. 响应中断： 如果检测到中断，可以根据任务的性质决定是否立即响应中断。如果任务可以安全地中断，可以使用 Thread.interrupt() 方法清除中断状态并抛出 InterruptedException 异常。

   try {
       // 执行任务
   } catch (InterruptedException e) {
       // 清除中断状态并处理中断
       Thread.currentThread().interrupt();
   }
   

3. 优雅地关闭线程： 如果任务无法安全地中断，可以考虑使用一个标志变量来表示任务已经完成。在执行任务的过程中，定期检查这个标志变量，如果发现需要停止任务，可以退出循环或方法。

   volatile boolean isInterrupted = false;
   
   while (!isInterrupted) {
       // 执行任务
   
       // 检查中断状态
       if (Thread.interrupted()) {
           isInterrupted = true;
       }
   }
   

4. 使用 ExecutorService： 如果使用 ExecutorService 管理线程，可以通过调用 shutdownNow() 方法来请求中断所有任务。这些任务应该能够响应中断并安全地关闭。

   ExecutorService executor = Executors.newFixedThreadPool(5);
   
   // 提交任务
   Future<?> future = executor.submit(() -> {
       // 执行任务
   });
   
   // 请求中断任务
   future.cancel(true);
   
   // 关闭线程池
   executor.shutdown();
   

总之，处理 Java 线程中断时，需要检查中断状态，根据任务的性质决定是否响应中断，优雅地关闭线程，以及使用 ExecutorService 管理线程。