org.apache.mina.core

类 IoUtil

java.lang.Object

org.apache.mina.core.IoUtil

public final class IoUtil
extends java.lang.Object

A utility class that provides various convenience methods related with IoSession and IoFuture.

作者:

Apache MINA Project

方法概要

方法

限定符和类型	方法和说明
static void	await(java.lang.Iterable<? extends IoFuture> futures)
static boolean	await(java.lang.Iterable<? extends IoFuture> futures, long timeoutMillis)
static boolean	await(java.lang.Iterable<? extends IoFuture> futures, long timeout, java.util.concurrent.TimeUnit unit)
static void	awaitUninterruptably(java.lang.Iterable<? extends IoFuture> futures)
static boolean	awaitUninterruptibly(java.lang.Iterable<? extends IoFuture> futures, long timeoutMillis)
static boolean	awaitUninterruptibly(java.lang.Iterable<? extends IoFuture> futures, long timeout, java.util.concurrent.TimeUnit unit)
static java.util.List<WriteFuture>	broadcast(java.lang.Object message, java.util.Collection<IoSession> sessions) Writes the specified message to the specified sessions.
static java.util.List<WriteFuture>	broadcast(java.lang.Object message, IoSession... sessions) Writes the specified message to the specified sessions.
static java.util.List<WriteFuture>	broadcast(java.lang.Object message, java.lang.Iterable<IoSession> sessions) Writes the specified message to the specified sessions.
static java.util.List<WriteFuture>	broadcast(java.lang.Object message, java.util.Iterator<IoSession> sessions) Writes the specified message to the specified sessions.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

broadcast

public static java.util.List<WriteFuture> broadcast(java.lang.Object message,
                                    java.util.Collection<IoSession> sessions)

Writes the specified message to the specified sessions. If the specified message is an IoBuffer, the buffer is automatically duplicated using IoBuffer.duplicate().

参数:

message - The message to broadcast

sessions - The sessions that will receive the message

返回:

The list of WriteFuture created for each broadcasted message

broadcast

public static java.util.List<WriteFuture> broadcast(java.lang.Object message,
                                    java.lang.Iterable<IoSession> sessions)

Writes the specified message to the specified sessions. If the specified message is an IoBuffer, the buffer is automatically duplicated using IoBuffer.duplicate().

参数:

message - The message to broadcast

sessions - The sessions that will receive the message

返回:

The list of WriteFuture created for each broadcasted message

broadcast

public static java.util.List<WriteFuture> broadcast(java.lang.Object message,
                                    java.util.Iterator<IoSession> sessions)

Writes the specified message to the specified sessions. If the specified message is an IoBuffer, the buffer is automatically duplicated using IoBuffer.duplicate().

参数:

message - The message to write

sessions - The sessions the message has to be written to

返回:

The list of WriteFuture for the written messages

broadcast

public static java.util.List<WriteFuture> broadcast(java.lang.Object message,
                                    IoSession... sessions)

Writes the specified message to the specified sessions. If the specified message is an IoBuffer, the buffer is automatically duplicated using IoBuffer.duplicate().

参数:

message - The message to write

sessions - The sessions the message has to be written to

返回:

The list of WriteFuture for the written messages

await

public static void await(java.lang.Iterable<? extends IoFuture> futures)
                  throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

awaitUninterruptably

public static void awaitUninterruptably(java.lang.Iterable<? extends IoFuture> futures)

await

public static boolean await(java.lang.Iterable<? extends IoFuture> futures,
            long timeout,
            java.util.concurrent.TimeUnit unit)
                     throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

await

public static boolean await(java.lang.Iterable<? extends IoFuture> futures,
            long timeoutMillis)
                     throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

awaitUninterruptibly

public static boolean awaitUninterruptibly(java.lang.Iterable<? extends IoFuture> futures,
                           long timeout,
                           java.util.concurrent.TimeUnit unit)

awaitUninterruptibly

public static boolean awaitUninterruptibly(java.lang.Iterable<? extends IoFuture> futures,
                           long timeoutMillis)