public class DefaultIoFuture extends java.lang.Object implements IoFuture
Constructor and Description |
---|
DefaultIoFuture(IoSession session)
Creates a new instance associated with an
IoSession . |
Modifier and Type | Method and Description |
---|---|
IoFuture |
addListener(IoFutureListener<?> listener)
Adds an event listener which is notified when
this future is completed.
|
IoFuture |
await()
Wait for the asynchronous operation to complete.
|
boolean |
await(long timeoutMillis)
Wait for the asynchronous operation to complete with the specified timeout.
|
boolean |
await(long timeout,
java.util.concurrent.TimeUnit unit)
Wait for the asynchronous operation to complete with the specified timeout.
|
IoFuture |
awaitUninterruptibly()
Wait for the asynchronous operation to complete uninterruptibly.
|
boolean |
awaitUninterruptibly(long timeoutMillis)
Wait for the asynchronous operation to complete with the specified timeout
uninterruptibly.
|
boolean |
awaitUninterruptibly(long timeout,
java.util.concurrent.TimeUnit unit)
Wait for the asynchronous operation to complete with the specified timeout
uninterruptibly.
|
IoSession |
getSession()
Returns the
IoSession which is associated with this future. |
protected java.lang.Object |
getValue()
Returns the result of the asynchronous operation.
|
boolean |
isDone()
Returns if the asynchronous operation is completed.
|
void |
join()
Deprecated.
Replaced with
awaitUninterruptibly() . |
boolean |
join(long timeoutMillis)
Deprecated.
Replaced with
awaitUninterruptibly(long) . |
IoFuture |
removeListener(IoFutureListener<?> listener)
Removes an existing event listener so it won't be notified when
the future is completed.
|
void |
setValue(java.lang.Object newValue)
Sets the result of the asynchronous operation, and mark it as finished.
|
public IoSession getSession()
IoSession
which is associated with this future.getSession
in interface IoFuture
@Deprecated public void join()
awaitUninterruptibly()
.@Deprecated public boolean join(long timeoutMillis)
awaitUninterruptibly(long)
.public IoFuture await() throws java.lang.InterruptedException
public boolean await(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
public boolean await(long timeoutMillis) throws java.lang.InterruptedException
public IoFuture awaitUninterruptibly()
awaitUninterruptibly
in interface IoFuture
public boolean awaitUninterruptibly(long timeout, java.util.concurrent.TimeUnit unit)
awaitUninterruptibly
in interface IoFuture
public boolean awaitUninterruptibly(long timeoutMillis)
awaitUninterruptibly
in interface IoFuture
public boolean isDone()
public void setValue(java.lang.Object newValue)
protected java.lang.Object getValue()
public IoFuture addListener(IoFutureListener<?> listener)
addListener
in interface IoFuture
public IoFuture removeListener(IoFutureListener<?> listener)
removeListener
in interface IoFuture
Copyright © 2004-2019 Apache MINA Project. All Rights Reserved.