Java并发编程：线程池超时处理案例

原创阳光穿透心脏的1/2处 2024-10-23 04:42 8阅读 0赞

在Java的并发编程中，线程池是一种常用的管理线程的方式。当线程池中的任务执行超时时，我们需要进行相应的错误处理和提示。

以下是一个简单的案例：

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

public class ThreadPoolTimeoutExample {

public static void main(String[] args) {
        // 创建线程池，核心线程数为1，最大线程数为5
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池，设置超时时间（这里设为2秒）
        Future<Integer> future = executor.submit(() -> {
            try {
                Thread.sleep(500); // 模拟耗时操作
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return 42; // 预期返回值
        }), 2, TimeUnit.SECONDS);

// 处理线程池返回的Future对象
        try {
            Integer result = future.get(); // 获取结果，如果超时则抛出TimeoutException
            System.out.println("任务执行结果： " + result);
            // 关闭线程池，释放资源
            executor.shutdown();
        } catch (TimeoutException e) {
            System.err.println("任务执行超时：" + e.getMessage());
        } catch (InterruptedException e) {
            System.err.println("获取任务执行结果时发生中断：" + e.getMessage());
        }
    }
}
```

在这个例子中，我们创建了一个线程池，并提交了一个耗时的任务到线程池。通过设置超时时间（这里设为2秒），如果任务在规定时间内没有完成，那么线程池会抛出`TimeoutException`。

你可以根据实际需求修改这个案例的代码。