V
- public interface BulkFuture<V>
extends java.util.concurrent.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 |
---|---|
java.util.concurrent.Future<V> |
addListener(BulkGetCompletionListener listener)
Add a listener to the future, which will be executed once the operation
completes.
|
V |
getSome(long timeout,
java.util.concurrent.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() |
java.util.concurrent.Future<V> |
removeListener(BulkGetCompletionListener listener)
Remove a previously added listener from the future.
|
boolean isTimeout()
V getSome(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
Future.get(long, TimeUnit)
timeout
- unit
- java.lang.InterruptedException
java.util.concurrent.ExecutionException
OperationStatus getStatus()
java.util.concurrent.Future<V> addListener(BulkGetCompletionListener listener)
listener
- the listener which will be executed.java.util.concurrent.Future<V> removeListener(BulkGetCompletionListener listener)
listener
- the previously added listener.Copyright © 2006-2009 Dustin Sallings, 2009-2013 Couchbase, Inc.