Skip to content

Commit 67f9417

Browse files
committed
Make CompletableTask potentially extendable to RunnablePromise (protected access to runTask)
1 parent 356be4b commit 67f9417

File tree

2 files changed

+6
-4
lines changed

2 files changed

+6
-4
lines changed

src/main/java/net/tascalate/concurrent/CompletableTask.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -240,6 +240,10 @@ public static Promise<Duration> delay(Duration duration, Executor executor) {
240240
.unwrap();
241241
}
242242

243+
protected void runTask() {
244+
task.run();
245+
}
246+
243247
@Override
244248
void fireTransition(Callable<T> code) {
245249
throw new UnsupportedOperationException();

src/main/java/net/tascalate/concurrent/TaskExecutors.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@
1919
import java.util.List;
2020

2121
import java.util.concurrent.Callable;
22-
import java.util.concurrent.CompletableFuture;
2322
import java.util.concurrent.ExecutionException;
2423
import java.util.concurrent.Executor;
2524
import java.util.concurrent.ExecutorService;
@@ -185,8 +184,7 @@ static <T> RunnablePromise<T> newRunnablePromise(Executor executor, Callable<T>
185184
}
186185

187186
static class RunnableCompletableTask<T> extends CompletableTask<T>
188-
implements RunnablePromise<T>,
189-
CompletableFuture.AsynchronousCompletionTask{
187+
implements RunnablePromise<T> {
190188

191189
RunnableCompletableTask(Executor executor, Callable<T> callable) {
192190
super(executor, callable);
@@ -195,7 +193,7 @@ static class RunnableCompletableTask<T> extends CompletableTask<T>
195193

196194
@Override
197195
public void run() {
198-
task.run();
196+
runTask();
199197
}
200198
}
201199

0 commit comments

Comments
 (0)