面试必会：Java并发编程中ThreadInterruptedException的实战案例

原创逃离我推掉我的手 2024-11-27 10:51 0阅读 0赞

`ThreadInterruptedException`是Java并发编程中一个特殊异常，它会在线程在等待某个条件时，中断请求被抛出。

实战案例1：无限循环中的中断

```java
public class InfiniteLoopInterrupt {
    public void infiniteLoop() throws InterruptedException {
        while (true) {  // 无限循环
            if (System.currentTimeMillis() > 5000) {  // 5秒超时，触发中断
                System.out.println("中断已触发，停止无限循环");
                break;
            }
            Thread.sleep(100);  // 模拟耗时操作
        }
    }

public static void main(String[] args) {
        InfiniteLoopInterrupt il = new InfiniteLoopInterrupt();
        try {
            il.infiniteLoop();
        } catch (InterruptedException e) {
            System.out.println("中断发生：" + e.getMessage());
            e.printStackTrace();  // 打印异常堆栈
        }
    }
}
```

在这个案例中，线程无限循环并在每100毫秒进行模拟耗时操作。当程序运行5秒后，会抛出`InterruptedException`。

实战案例2：线程池中的任务中断

```java
import java.util.concurrent.Executors;
import java.util.concurrent.Interrupter;

public class ThreadPoolInterruptExample {
    public static void main(String[] args) {
        // 创建线程池和中断器
        Executors executor = Executors.newFixedThreadPool(5);
        Interrupter interrupter = executor.newInterrupter();

// 定义任务并设置中断条件
        Runnable task = () -> {
            try {
                Thread.sleep(2000);  // 模拟耗时操作
            } catch (InterruptedException e) {
                interrupter.interrupt(e);
            }
            System.out.println("中断已触发，停止任务");
        };

// 启动任务，并在满足中断条件时中断
        task.run();
    }
}
```

在这个案例中，我们使用了Java的`Executors`线程池和`Interrupter`来处理中断。当模拟耗时操作超过2秒时，会抛出`InterruptedException`，并被中断器捕获并打断任务执行。

总结：在理解和编写Java并发编程时，`ThreadInterruptedException`是经常会遇到的一个异常类型，用于表示线程在等待某个条件满足时，因中断请求被抛出。