org.apache.hadoop.hbase.util

Class BoundedCompletionService<V>

java.lang.Object

org.apache.hadoop.hbase.util.BoundedCompletionService<V>

@InterfaceAudience.Private
public class BoundedCompletionService<V>
extends Object

A completion service, close to the one available in the JDK 1.7 However, this ones keeps the list of the future, and allows to cancel them all. This means as well that it can be used for a small set of tasks only.
Implementation is not Thread safe.

Constructor Summary

Constructors

Constructor and Description
BoundedCompletionService(Executor executor, int maxTasks)

Method Summary

Modifier and Type	Method and Description
void	cancelAll(boolean interrupt)
Future<V>	poll(long timeout, TimeUnit unit)
Future<V>	submit(Callable<V> task)
Future<V>	take()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BoundedCompletionService

public BoundedCompletionService(Executor executor,
                                int maxTasks)

Method Detail

submit

public Future<V> submit(Callable<V> task)

take

public Future<V> take()
               throws InterruptedException

Throws:

InterruptedException

poll

public Future<V> poll(long timeout,
                      TimeUnit unit)
               throws InterruptedException

Throws:

InterruptedException

cancelAll

public void cancelAll(boolean interrupt)