在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异常时,我们重新设置中断状态。
需要注意的是,中断信号并不会立即中断线程,而是设置一个中断标志,线程在合适的时机检查这个标志来决定是否中断执行。