public class DefaultIoFuture extends java.lang.Object implements IoFuture
IoFuture.| Constructor and Description |
|---|
DefaultIoFuture(IoSession session)
Creates a new instance.
|
DefaultIoFuture(IoSession session,
java.lang.Object lock)
Creates a new instance.
|
| Modifier and Type | Method and Description |
|---|---|
void |
addListener(IoFutureListener listener)
Adds an event listener which is notified when
the state of this future changes.
|
java.lang.Object |
getLock()
Returns the lock object this future acquires.
|
IoSession |
getSession()
Returns the
IoSession which is associated with this future. |
protected java.lang.Object |
getValue()
Returns the result of the asynchronous operation.
|
boolean |
isReady()
Returns if the asynchronous operation is finished.
|
void |
join()
Wait for the asynchronous operation to end.
|
boolean |
join(long timeoutMillis)
Wait for the asynchronous operation to end with the specified timeout.
|
void |
removeListener(IoFutureListener listener)
Removes an existing event listener which is notified when
the state of this future changes.
|
protected void |
setValue(java.lang.Object newValue)
Sets the result of the asynchronous operation, and mark it as finished.
|
public DefaultIoFuture(IoSession session)
session - an IoSession which is associated with this futurepublic IoSession getSession()
IoFutureIoSession which is associated with this future.getSession in interface IoFuturepublic java.lang.Object getLock()
IoFuturepublic void join()
IoFuturepublic boolean join(long timeoutMillis)
IoFuturepublic boolean isReady()
IoFutureprotected void setValue(java.lang.Object newValue)
protected java.lang.Object getValue()
public void addListener(IoFutureListener listener)
IoFutureaddListener in interface IoFuturepublic void removeListener(IoFutureListener listener)
IoFutureremoveListener in interface IoFuture