public class IoThreadPoolFilter extends BaseThreadPool implements ThreadPool, IoFilter
IoHandler
events
to its thread pool.ThreadPool
,
BaseThreadPool
BaseThreadPool.SessionBuffer
IoFilter.NextFilter
DEFAULT_KEEP_ALIVE_TIME, DEFAULT_MAXIMUM_POOL_SIZE
Constructor and Description |
---|
IoThreadPoolFilter()
Creates a new instance of this filter with default thread pool settings.
|
IoThreadPoolFilter(java.lang.String threadNamePrefix)
Creates a new instance of this filter with default thread pool settings.
|
fetchSessionBuffer, fireEvent, getKeepAliveTime, getMaximumPoolSize, getPoolSize, getThreadNamePrefix, setKeepAliveTime, setMaximumPoolSize, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getKeepAliveTime, getMaximumPoolSize, getPoolSize, setKeepAliveTime, setMaximumPoolSize, start, stop
public IoThreadPoolFilter()
BaseThreadPool.start()
method to start threads actually.public IoThreadPoolFilter(java.lang.String threadNamePrefix)
BaseThreadPool.start()
method to start threads actually.threadNamePrefix
- the prefix of the thread names this pool will create.public void sessionOpened(IoFilter.NextFilter nextFilter, IoSession session)
IoFilter
IoHandler.sessionOpened(IoSession)
event.sessionOpened
in interface IoFilter
public void sessionClosed(IoFilter.NextFilter nextFilter, IoSession session)
IoFilter
IoHandler.sessionClosed(IoSession)
event.sessionClosed
in interface IoFilter
public void sessionIdle(IoFilter.NextFilter nextFilter, IoSession session, IdleStatus status)
IoFilter
IoHandler.sessionIdle(IoSession, IdleStatus)
event.sessionIdle
in interface IoFilter
public void exceptionCaught(IoFilter.NextFilter nextFilter, IoSession session, java.lang.Throwable cause)
IoFilter
IoHandler.exceptionCaught(IoSession, Throwable)
event.exceptionCaught
in interface IoFilter
public void dataRead(IoFilter.NextFilter nextFilter, IoSession session, ByteBuffer buf)
IoFilter
IoHandler.dataRead(IoSession, ByteBuffer)
event.public void dataWritten(IoFilter.NextFilter nextFilter, IoSession session, java.lang.Object marker)
IoFilter
IoHandler.dataWritten(IoSession, Object)
event.dataWritten
in interface IoFilter
protected void processEvent(java.lang.Object nextFilter0, Session session0, EventType type, java.lang.Object data)
BaseThreadPool
processEvent
in class BaseThreadPool
public void filterWrite(IoFilter.NextFilter nextFilter, IoSession session, ByteBuffer buf, java.lang.Object marker) throws java.lang.Exception
IoFilter
IoSession.write(ByteBuffer, Object)
method invocation.filterWrite
in interface IoFilter
java.lang.Exception