public class ExecutorAllCompletionService extends Object implements CompletionService<Void>
Constructor and Description |
---|
ExecutorAllCompletionService(Executor executor) |
Modifier and Type | Method and Description |
---|---|
long |
getCompletedTasks() |
ExecutionException |
getFirstException() |
long |
getScheduledTasks() |
boolean |
isAllCompleted() |
boolean |
isExceptionThrown() |
Future<Void> |
poll() |
Future<Void> |
poll(long timeout,
TimeUnit unit) |
Future<Void> |
submit(Callable<Void> task) |
Future<Void> |
submit(Runnable task,
Void result) |
Future<Void> |
take() |
void |
waitUntilAllCompleted() |
public ExecutorAllCompletionService(Executor executor)
public Future<Void> submit(Callable<Void> task)
submit
in interface CompletionService<Void>
public Future<Void> submit(Runnable task, Void result)
submit
in interface CompletionService<Void>
public boolean isAllCompleted()
public long getScheduledTasks()
public long getCompletedTasks()
public void waitUntilAllCompleted()
public boolean isExceptionThrown()
public ExecutionException getFirstException()
public Future<Void> take() throws InterruptedException
take
in interface CompletionService<Void>
InterruptedException
public Future<Void> poll()
poll
in interface CompletionService<Void>
public Future<Void> poll(long timeout, TimeUnit unit) throws InterruptedException
poll
in interface CompletionService<Void>
InterruptedException
Copyright © 2021 JBoss by Red Hat. All rights reserved.