在Java中处理中断信号通常使用Thread类的interrupt()方法来发送中断信号,以及使用Thread类的isInterrupted()方法或者interrupted()方法来检查线程是否被中断。下面是一个简单的示例代码:
public class Main { public static void main(String[] args) { Thread thread = new Thread(() -> { while (!Thread.currentThread().isInterrupted()) { // 执行一些任务 System.out.println("Running task..."); try { Thread.sleep(1000); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } }); thread.start(); // 在某个时间点发送中断信号 try { Thread.sleep(5000); thread.interrupt(); } catch (InterruptedException e) { e.printStackTrace(); } } }
在上面的示例中,我们创建了一个新的线程并在其中执行一个任务,然后在5秒后发送中断信号给线程。线程在执行任务时会检查是否被中断,如果被中断则停止执行任务。在捕获到InterruptedException异常时,我们重新设置中断状态。
需要注意的是,中断信号并不会立即中断线程,而是设置一个中断标志,线程在合适的时机检查这个标志来决定是否中断执行。