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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	BoundedCompletionService.QueueingFuture

Field Summary

Fields

Modifier and Type	Field and Description
private BlockingQueue<Future<V>>	completed
private Executor	executor
private List<Future<V>>	tasks

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

Field Detail

executor

private final Executor executor

tasks

private final List<Future<V>> tasks

completed

private final BlockingQueue<Future<V>> completed

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)