BoundedCompletionService (Apache HBase 1.4.11 API)

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

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

Methods
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)

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.