T
- types of objects returned from the GETpublic class BulkGetFuture<T> extends java.lang.Object 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) |
Modifier and Type | Method and Description |
---|---|
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() |
void |
setStatus(OperationStatus s) |
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>>
Copyright © 2006-2009 Dustin Sallings, 2009-2013 Couchbase, Inc.