public class ReplicaGetFuture<T> extends net.spy.memcached.internal.AbstractListenableFuture<T,ReplicaGetCompletionListener> implements java.util.concurrent.Future<T>
Constructor and Description |
---|
ReplicaGetFuture(long timeout,
java.util.concurrent.ExecutorService service) |
Modifier and Type | Method and Description |
---|---|
void |
addFutureToMonitor(net.spy.memcached.internal.GetFuture<T> future)
Add a
GetFuture to mointor. |
ReplicaGetFuture<T> |
addListener(ReplicaGetCompletionListener listener) |
boolean |
cancel(boolean ign) |
T |
get() |
T |
get(long userTimeout,
java.util.concurrent.TimeUnit unit) |
boolean |
isCancelled() |
boolean |
isDone() |
ReplicaGetFuture<T> |
removeListener(ReplicaGetCompletionListener listener) |
void |
setCompletedFuture(net.spy.memcached.internal.GetFuture<T> future)
Mark a monitored future as complete.
|
public ReplicaGetFuture(long timeout, java.util.concurrent.ExecutorService service)
public void addFutureToMonitor(net.spy.memcached.internal.GetFuture<T> future)
GetFuture
to mointor.
Note that this method is for internal use only.future
- the future to monitor.public void setCompletedFuture(net.spy.memcached.internal.GetFuture<T> future)
future
- the future to mark as completed.public T get() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
get
in interface java.util.concurrent.Future<T>
java.lang.InterruptedException
java.util.concurrent.ExecutionException
public T get(long userTimeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
get
in interface java.util.concurrent.Future<T>
java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.util.concurrent.TimeoutException
public boolean cancel(boolean ign)
cancel
in interface java.util.concurrent.Future<T>
public boolean isCancelled()
isCancelled
in interface java.util.concurrent.Future<T>
public boolean isDone()
isDone
in interface java.util.concurrent.Future<T>
public ReplicaGetFuture<T> addListener(ReplicaGetCompletionListener listener)
addListener
in interface net.spy.memcached.internal.ListenableFuture<T,ReplicaGetCompletionListener>
public ReplicaGetFuture<T> removeListener(ReplicaGetCompletionListener listener)
removeListener
in interface net.spy.memcached.internal.ListenableFuture<T,ReplicaGetCompletionListener>
Copyright © 2006-2009 Dustin Sallings, 2009-2012 Couchbase, Inc.