stu/asyncTool
1
0
Fork 0
mirror of https://gitee.com/jd-platform-opensource/asyncTool.git synced 2026-03-22 04:27:15 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

refactor: 加上线程已经取消的情况

Browse Source
This commit is contained in:
kyle
2023-02-01 19:27:57 +08:00
parent ffe9056600
commit e56521caf3
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -14,6 +14,7 @@ import java.util.*;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicReference;
import java.util.function.Predicate;
import java.util.stream.Collectors;
/**
@@ -102,7 +103,8 @@ public class Async {
} catch (InterruptedException e) {
e.printStackTrace();
}
if (onceWork.getAllThreadSubmit().stream().allMatch(Future::isDone)) {
//完成或者取消就及时取消任务
if (onceWork.getAllThreadSubmit().stream().allMatch(future -> future.isDone()|| future.isCancelled())) {
if (!onceWork.isCancelled() && !onceWork.isWaitingCancel()) {
onceWork.pleaseCancel();
}