public class HttpFuture<T> extends net.spy.memcached.internal.AbstractListenableFuture<T,HttpCompletionListener> implements java.util.concurrent.Future<T>
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.CountDownLatch |
latch |
protected java.util.concurrent.atomic.AtomicReference<T> |
objRef |
protected HttpOperation |
op |
protected net.spy.memcached.ops.OperationStatus |
status |
protected long |
timeout |
Constructor and Description |
---|
HttpFuture(java.util.concurrent.CountDownLatch latch,
long timeout,
java.util.concurrent.ExecutorService service) |
Modifier and Type | Method and Description |
---|---|
HttpFuture<T> |
addListener(HttpCompletionListener listener) |
boolean |
cancel(boolean c) |
T |
get() |
T |
get(long duration,
java.util.concurrent.TimeUnit units) |
net.spy.memcached.ops.OperationStatus |
getStatus() |
boolean |
isCancelled() |
boolean |
isDone() |
HttpFuture<T> |
removeListener(HttpCompletionListener listener) |
void |
set(T oper,
net.spy.memcached.ops.OperationStatus s) |
void |
setOperation(HttpOperation to) |
protected void |
waitForAndCheckOperation(long duration,
java.util.concurrent.TimeUnit units) |
protected final java.util.concurrent.atomic.AtomicReference<T> objRef
protected final java.util.concurrent.CountDownLatch latch
protected final long timeout
protected net.spy.memcached.ops.OperationStatus status
protected HttpOperation op
public HttpFuture(java.util.concurrent.CountDownLatch latch, long timeout, java.util.concurrent.ExecutorService service)
public boolean cancel(boolean c)
cancel
in interface java.util.concurrent.Future<T>
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 duration, java.util.concurrent.TimeUnit units) 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
protected void waitForAndCheckOperation(long duration, java.util.concurrent.TimeUnit units) throws java.lang.InterruptedException, java.util.concurrent.TimeoutException, java.util.concurrent.ExecutionException
java.lang.InterruptedException
java.util.concurrent.TimeoutException
java.util.concurrent.ExecutionException
public net.spy.memcached.ops.OperationStatus getStatus()
public void set(T oper, net.spy.memcached.ops.OperationStatus s)
public boolean isDone()
isDone
in interface java.util.concurrent.Future<T>
public void setOperation(HttpOperation to)
public boolean isCancelled()
isCancelled
in interface java.util.concurrent.Future<T>
public HttpFuture<T> addListener(HttpCompletionListener listener)
addListener
in interface net.spy.memcached.internal.ListenableFuture<T,HttpCompletionListener>
public HttpFuture<T> removeListener(HttpCompletionListener listener)
removeListener
in interface net.spy.memcached.internal.ListenableFuture<T,HttpCompletionListener>
Copyright © 2006-2009 Dustin Sallings, 2009-2012 Couchbase, Inc.