V
- public interface BulkFuture<V> extends Future<V>
This interface is now returned from all asyncGetBulk methods. Unlike
Future.get(long, TimeUnit)
, getSome(long, TimeUnit)
does not throw
CheckedOperationTimeoutException, thus allowing retrieval of partial results
after timeout occurs. This behavior is especially useful in case of large
multi gets.
Modifier and Type | Method and Description |
---|---|
Future<V> |
addListener(BulkGetCompletionListener listener)
Add a listener to the future, which will be executed once the operation
completes.
|
V |
getSome(long timeout,
TimeUnit unit)
Wait for the operation to complete and return results
If operation could not complete within specified timeout, partial result is
returned.
|
OperationStatus |
getStatus()
Gets the status of the operation upon completion.
|
boolean |
isTimeout() |
Future<V> |
removeListener(BulkGetCompletionListener listener)
Remove a previously added listener from the future.
|
boolean isTimeout()
V getSome(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException
Future.get(long, TimeUnit)
timeout
- unit
- InterruptedException
ExecutionException
OperationStatus getStatus()
Future<V> addListener(BulkGetCompletionListener listener)
listener
- the listener which will be executed.Future<V> removeListener(BulkGetCompletionListener listener)
listener
- the previously added listener.Copyright © 2024. All rights reserved.