etl
/
cloud-etl-task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改超时时间

master
Cui YongXing 2024-09-11 00:14:29 +08:00
parent 9bfc6e0c61
commit 74662d0dec
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
View File

@ -272,18 +272,18 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
executorService.shutdown(); executorService.shutdown();
// 等待所有任务完成（可选） // 等待所有任务完成（可选）
try { // try {
if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) { // if (!executorService.awaitTermination()) {
// 如果在指定时间内没有完成，可以选择取消当前正在执行的任务 // // 如果在指定时间内没有完成，可以选择取消当前正在执行的任务
executorService.shutdownNow(); // executorService.shutdownNow();
// 然后根据需要处理超时情况 // // 然后根据需要处理超时情况
} // }
} catch (InterruptedException e) { // } catch (InterruptedException e) {
// 当前线程在等待过程中被中断 // // 当前线程在等待过程中被中断
executorService.shutdownNow(); // executorService.shutdownNow();
// 当前线程需要处理中断情况 // // 当前线程需要处理中断情况
Thread.currentThread().interrupt(); // Thread.currentThread().interrupt();
} // }
} }