wangli/im-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-2481: 简单重构

Browse Source
This commit is contained in:
yanglin 2024-06-03 17:54:02 +08:00
parent 7100dc09db
commit ca37177e12
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
im-center-server/src/main/java/cn/axzo/im/send/AsyncTasks.java
View File

@ -14,19 +14,19 @@ import java.util.concurrent.TimeoutException;
class AsyncTasks<T> {
private final List<CompletableFuture<T>> futures = Collections.synchronizedList(new ArrayList<>());
private final boolean removeWhenComplete;
private final boolean removeFutureWhenComplete;
AsyncTasks() {
this(true);
}
AsyncTasks(boolean removeWhenComplete) {
this.removeWhenComplete = removeWhenComplete;
AsyncTasks(boolean removeFutureWhenComplete) {
this.removeFutureWhenComplete = removeFutureWhenComplete;
}
void add(CompletableFuture<T> future) {
futures.add(future);
if (removeWhenComplete)
if (removeFutureWhenComplete)
future.whenComplete((unused, throwable) -> futures.remove(future));
}