org.apache.mina.core.future

接口 ReadFuture

所有超级接口:

IoFuture

所有已知实现类:

DefaultReadFuture

public interface ReadFuture
extends IoFuture

An IoFuture for asynchronous read requests.

Example

 IoSession session = ...;
 
 // useReadOperation must be enabled to use read operation.
 session.getConfig().setUseReadOperation(true);
 
 ReadFuture future = session.read();
 
 // Wait until a message is received.
 future.awaitUninterruptibly();
 
 try {
     Object message = future.getMessage();
 } catch (Exception e) {
     ...
 }
 

作者:

Apache MINA Project

方法概要

方法

限定符和类型	方法和说明
ReadFuture	addListener(IoFutureListener<?> listener) Adds an event listener which is notified when this future is completed.
ReadFuture	await() Wait for the asynchronous operation to complete.
ReadFuture	awaitUninterruptibly() Wait for the asynchronous operation to complete uninterruptibly.
java.lang.Throwable	getException()
java.lang.Object	getMessage() Get the read message.
boolean	isClosed()
boolean	isRead()
ReadFuture	removeListener(IoFutureListener<?> listener) Removes an existing event listener so it won't be notified when the future is completed.
void	setClosed() Sets the associated IoSession is closed.
void	setException(java.lang.Throwable cause) Sets the cause of the read failure, and notifies all threads waiting for this future.
void	setRead(java.lang.Object message) Sets the message is written, and notifies all threads waiting for this future.

从接口继承的方法 org.apache.mina.core.future.IoFuture

await, await, awaitUninterruptibly, awaitUninterruptibly, getSession, isDone, join, join

方法详细资料

getMessage

java.lang.Object getMessage()

Get the read message.

返回:

the received message. It returns null if this future is not ready or the associated IoSession has been closed.

isRead

boolean isRead()

返回:

true if a message was received successfully.

isClosed

boolean isClosed()

返回:

true if the IoSession associated with this future has been closed.

getException

java.lang.Throwable getException()

返回:

the cause of the read failure if and only if the read operation has failed due to an Exception. Otherwise, null is returned.

setRead

void setRead(java.lang.Object message)

Sets the message is written, and notifies all threads waiting for this future. This method is invoked by MINA internally. Please do not call this method directly.

参数:

message - The received message to store in this future

setClosed

void setClosed()

Sets the associated IoSession is closed. This method is invoked by MINA internally. Please do not call this method directly.

setException

void setException(java.lang.Throwable cause)

Sets the cause of the read failure, and notifies all threads waiting for this future. This method is invoked by MINA internally. Please do not call this method directly.

参数:

cause - The exception to store in the Future instance

await

ReadFuture await()
                 throws java.lang.InterruptedException

Wait for the asynchronous operation to complete. The attached listeners will be notified when the operation is completed.

指定者:

await 在接口中 IoFuture

返回:

The instance of IoFuture that we are waiting for

抛出:

java.lang.InterruptedException - If the thread is interrupted while waiting

awaitUninterruptibly

ReadFuture awaitUninterruptibly()

Wait for the asynchronous operation to complete uninterruptibly. The attached listeners will be notified when the operation is completed.

指定者:

awaitUninterruptibly 在接口中 IoFuture

返回:

the current IoFuture

addListener

ReadFuture addListener(IoFutureListener<?> listener)

Adds an event listener which is notified when this future is completed. If the listener is added after the completion, the listener is directly notified.

指定者:

addListener 在接口中 IoFuture

参数:

listener - The listener to add

返回:

the current IoFuture

removeListener

ReadFuture removeListener(IoFutureListener<?> listener)

Removes an existing event listener so it won't be notified when the future is completed.

指定者:

removeListener 在接口中 IoFuture

参数:

listener - The listener to remove

返回:

the current IoFuture