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

add awaitInterruptibly methods

Browse Source
This commit is contained in:
WhatCats
2024-05-21 14:41:22 +02:00
parent 1269f6ae94
commit daa05d93a0
3 changed files with 26 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -63,14 +63,16 @@ public abstract class AbstractPromise<T, F> implements Promise<T> {
}
@Override
public T await(long timeoutMillis) throws TimeoutException {
try {
boolean success = this.latch.await(timeoutMillis, TimeUnit.MILLISECONDS);
if (!success) {
throw new TimeoutException("Promise stopped waiting after " + timeoutMillis + "ms");
}
} catch (InterruptedException e) {
throw new RuntimeException(e);
public T awaitInterruptibly() throws InterruptedException {
this.latch.await();
return joinCompletion(Objects.requireNonNull(getCompletion()));
}
@Override
public T awaitInterruptibly(long timeoutMillis) throws TimeoutException, InterruptedException {
boolean success = this.latch.await(timeoutMillis, TimeUnit.MILLISECONDS);
if (!success) {
throw new TimeoutException("Promise stopped waiting after " + timeoutMillis + "ms");
}
return joinCompletion(Objects.requireNonNull(getCompletion()));
@@ -79,14 +81,20 @@ public abstract class AbstractPromise<T, F> implements Promise<T> {
@Override
public T await() {
try {
this.latch.await();
return awaitInterruptibly();
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
return joinCompletion(Objects.requireNonNull(getCompletion()));
}
@Override
public T await(long timeoutMillis) throws TimeoutException {
try {
return awaitInterruptibly(timeoutMillis);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
private T joinCompletion(PromiseCompletion<T> completion) {
if (completion.isError())

6
futur-api/src/main/java/dev/tommyjs/futur/promise/Promise.java
View File

@@ -124,6 +124,12 @@ public interface Promise<T> {
void completeExceptionally(@NotNull Throwable result);
@Blocking
T awaitInterruptibly() throws InterruptedException;
@Blocking
T awaitInterruptibly(long timeout) throws TimeoutException, InterruptedException;
@Blocking
T await();