public final class CompletionExecutor extends Object
ThreadPoolExecutor that can block until all posted operations
are completed.| Modifier and Type | Class and Description |
|---|---|
static interface |
CompletionExecutor.DebugContextRunnable
Interface implemented by tasks that want to be run via
CompletionExecutor.execute(DebugContextRunnable). |
static interface |
CompletionExecutor.Timing |
| Constructor and Description |
|---|
CompletionExecutor(BigBang bb,
ForkJoinPool forkJoin) |
| Modifier and Type | Method and Description |
|---|---|
long |
complete() |
void |
execute(CompletionExecutor.DebugContextRunnable command) |
ForkJoinPool |
getExecutorService() |
long |
getPostedOperations() |
void |
init() |
void |
init(CompletionExecutor.Timing newTiming) |
boolean |
isSequential() |
boolean |
isStarted() |
void |
shutdown() |
void |
start() |
public CompletionExecutor(BigBang bb, ForkJoinPool forkJoin)
public void init()
public void init(CompletionExecutor.Timing newTiming)
public void execute(CompletionExecutor.DebugContextRunnable command)
public void start()
public long complete()
throws InterruptedException
InterruptedExceptionpublic long getPostedOperations()
public boolean isSequential()
public void shutdown()
public boolean isStarted()
public ForkJoinPool getExecutorService()