ThreadPoolExecutor如何关闭
时间: 2024-04-11 12:24:39 浏览: 253
ThreadPoolExecutor是Java中用于管理线程池的类。要ThreadPoolExecutor,可以使用以下方法:
1. 调用`shutdown()`方法:这个方法会平缓地关闭线程池。它会停止接受新的任务,并且等待已经提交的任务执行完成。在所有任务执行完成后,线程池会被关闭。
2. 调用`shutdownNow()`方法:这个方法会立即关闭线程池。它会尝试停止所有正在执行的任务,并且不再处理等待执行的任务。该方法返回一个List,包含了未执行的任务。
在调用上述方法之后,可以使用`awaitTermination()`方法等待线程池完全关闭。这个方法会阻塞当前线程,直到线程池关闭或者超时。
下面是一个示例代码:
```java
ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.SECONDS, workQueue);
// 关闭线程池
executor.shutdown();
try {
// 等待线程池关闭,最多等待5秒钟
if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
// 如果超时,调用shutdownNow()方法强制关闭线程池
executor.shutdownNow();
// 再次等待线程池关闭
if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
System.err.println("线程池无法正常关闭");
}
}
} catch (InterruptedException e) {
// 捕获中断异常
executor.shutdownNow();
Thread.currentThread().interrupt();
}
```
阅读全文