mirrors/asyncTool
1
0
Fork 0
mirror of https://gitee.com/jd-platform-opensource/asyncTool.git synced 2024-12-31 15:35:34 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

chore: 简化判断

Browse Source
This commit is contained in:
kyle 2023-02-02 09:00:36 +08:00
parent 5efb329f9c
commit 6b546bc7a4
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
asyncTool-core/src/main/java/com/jd/platform/async/executor/Async.java
View File

@ -136,10 +136,8 @@ public class Async {
//任务结束就退出检查 //任务结束就退出检查
if (onceWork.isFinish()) { if (onceWork.isFinish()) {
break; break;
} } else if (onceWork.getAllThreadSubmit().stream().allMatch(future -> future.isDone() || future.isCancelled())) {
//完成或者取消就及时取消任务 //完成或者取消就及时取消任务
if (!onceWork.isFinish()
&& onceWork.getAllThreadSubmit().stream().allMatch(future -> future.isDone() || future.isCancelled())) {
if (!onceWork.isCancelled() && !onceWork.isWaitingCancel()) { if (!onceWork.isCancelled() && !onceWork.isWaitingCancel()) {
onceWork.pleaseCancel(); onceWork.pleaseCancel();
} }