@InterfaceAudience.Private public class BoundedCompletionService<V> extends java.lang.Object
Constructor and Description |
---|
BoundedCompletionService(java.util.concurrent.Executor executor,
int maxTasks) |
Modifier and Type | Method and Description |
---|---|
void |
cancelAll(boolean interrupt) |
java.util.concurrent.Future<V> |
poll(long timeout,
java.util.concurrent.TimeUnit unit) |
java.util.concurrent.Future<V> |
submit(java.util.concurrent.Callable<V> task) |
java.util.concurrent.Future<V> |
take() |
public BoundedCompletionService(java.util.concurrent.Executor executor, int maxTasks)
public java.util.concurrent.Future<V> take() throws java.lang.InterruptedException
java.lang.InterruptedException
public java.util.concurrent.Future<V> poll(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
java.lang.InterruptedException
public void cancelAll(boolean interrupt)