Package org.apache.hadoop.hbase.util

Class BoundedCompletionService<V>

java.lang.Object

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

@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	Description
(package private) class	BoundedCompletionService.QueueingFuture

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
BoundedCompletionService(Executor executor, int maxTasks)

Method Summary

Modifier and Type	Method	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 Details

executor

private final Executor executor

tasks

private final List<Future<V>> tasks

completed

private final BlockingQueue<Future<V>> completed

Constructor Details

BoundedCompletionService

public BoundedCompletionService(Executor executor,
 int maxTasks)

Method Details

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)