T
- types of objects returned from the GETpublic class BulkGetFuture<T> extends AbstractListenableFuture<java.util.Map<java.lang.String,T>,BulkGetCompletionListener> implements BulkFuture<java.util.Map<java.lang.String,T>>
Constructor and Description |
---|
BulkGetFuture(java.util.Map<java.lang.String,java.util.concurrent.Future<T>> m,
java.util.Collection<Operation> getOps,
java.util.concurrent.CountDownLatch l,
java.util.concurrent.ExecutorService service) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<java.util.Map<java.lang.String,T>> |
addListener(BulkGetCompletionListener listener)
Add a listener to the future, which will be executed once the operation
completes.
|
boolean |
cancel(boolean ign) |
java.util.Map<java.lang.String,T> |
get() |
java.util.Map<java.lang.String,T> |
get(long to,
java.util.concurrent.TimeUnit unit) |
java.util.Map<java.lang.String,T> |
getSome(long to,
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 |
isCancelled() |
boolean |
isDone() |
boolean |
isTimeout() |
java.util.concurrent.Future<java.util.Map<java.lang.String,T>> |
removeListener(BulkGetCompletionListener listener)
Remove a previously added listener from the future.
|
void |
setStatus(OperationStatus s) |
addToListeners, executor, notifyListener, notifyListeners, notifyListeners, removeFromListeners
public boolean cancel(boolean ign)
cancel
in interface java.util.concurrent.Future<java.util.Map<java.lang.String,T>>
public java.util.Map<java.lang.String,T> get() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
get
in interface java.util.concurrent.Future<java.util.Map<java.lang.String,T>>
java.lang.InterruptedException
java.util.concurrent.ExecutionException
public java.util.Map<java.lang.String,T> getSome(long to, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
BulkFuture
Future.get(long, TimeUnit)
getSome
in interface BulkFuture<java.util.Map<java.lang.String,T>>
java.lang.InterruptedException
java.util.concurrent.ExecutionException
public java.util.Map<java.lang.String,T> get(long to, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
get
in interface java.util.concurrent.Future<java.util.Map<java.lang.String,T>>
java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.util.concurrent.TimeoutException
public OperationStatus getStatus()
BulkFuture
getStatus
in interface BulkFuture<java.util.Map<java.lang.String,T>>
public void setStatus(OperationStatus s)
public boolean isCancelled()
isCancelled
in interface java.util.concurrent.Future<java.util.Map<java.lang.String,T>>
public boolean isDone()
isDone
in interface java.util.concurrent.Future<java.util.Map<java.lang.String,T>>
public boolean isTimeout()
isTimeout
in interface BulkFuture<java.util.Map<java.lang.String,T>>
public java.util.concurrent.Future<java.util.Map<java.lang.String,T>> addListener(BulkGetCompletionListener listener)
BulkFuture
addListener
in interface BulkFuture<java.util.Map<java.lang.String,T>>
addListener
in interface ListenableFuture<java.util.Map<java.lang.String,T>,BulkGetCompletionListener>
listener
- the listener which will be executed.public java.util.concurrent.Future<java.util.Map<java.lang.String,T>> removeListener(BulkGetCompletionListener listener)
BulkFuture
removeListener
in interface BulkFuture<java.util.Map<java.lang.String,T>>
removeListener
in interface ListenableFuture<java.util.Map<java.lang.String,T>,BulkGetCompletionListener>
listener
- the previously added listener.Copyright © 2006-2009 Dustin Sallings, 2009-2013 Couchbase, Inc.