tommyskeff/futur4j
1
0
Fork 0
mirror of https://github.com/tommyskeff/futur4j.git synced 2026-01-18 07:16:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

hotfix 2.1.1

Browse Source
This commit is contained in:
Tommy
2024-03-12 08:38:20 +00:00
parent 795ce04eb4
commit 0d5803262e
5 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
futur-api/src/main/java/dev/tommyjs/futur/promise/AbstractPromise.java
View File

@@ -13,6 +13,7 @@ import java.util.Collection;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;
public abstract class AbstractPromise<T> implements Promise<T> {
@@ -316,13 +317,14 @@ public abstract class AbstractPromise<T> implements Promise<T> {
}
protected void handleCompletion(@NotNull PromiseCompletion<T> ctx) {
AtomicReference<Boolean> success = new AtomicReference<>();
AtomicBoolean success = new AtomicBoolean();
completion.getAndUpdate(c -> {
if (c == null) {
return null;
} else {
success.set(true);
return ctx;
} else {
success.set(false);
return c;
}
});
@@ -339,7 +341,6 @@ public abstract class AbstractPromise<T> implements Promise<T> {
try {
listener.handle(ctx);
} catch (Exception e) {
e.printStackTrace();
getLogger().error("Exception caught in promise listener", e);
}
}