org.jboss.netty.channel.socket.nio

类 AbstractNioWorkerPool<E extends org.jboss.netty.channel.socket.nio.AbstractNioWorker>

java.lang.Object

org.jboss.netty.channel.socket.nio.AbstractNioWorkerPool<E>

所有已实现的接口:

NioSelectorPool, WorkerPool<E>, ExternalResourceReleasable

直接已知子类:

NioDatagramWorkerPool, NioWorkerPool

public abstract class AbstractNioWorkerPool<E extends org.jboss.netty.channel.socket.nio.AbstractNioWorker>
extends java.lang.Object
implements WorkerPool<E>, ExternalResourceReleasable

Abstract base class for WorkerPool implementations that create the Worker's up-front and return them in a "fair" fashion when calling nextWorker()

方法概要

方法

限定符和类型	方法和说明
protected void	init()
protected abstract E	newWorker(java.util.concurrent.Executor executor) Create a new Worker which uses the given Executor to service IO.
E	nextWorker() Return the next Worker to use
void	rebuildSelectors() Replaces the current Selectors of the Bosses with new Selectors to work around the infamous epoll 100% CPU bug.
void	releaseExternalResources() Releases the external resources that this object depends on.
void	shutdown() Shutdown the NioSelectorPool and all internal created resources

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

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

方法详细资料

init

protected void init()

newWorker

protected abstract E newWorker(java.util.concurrent.Executor executor)

Create a new Worker which uses the given Executor to service IO.

参数:

executor - the Executor to use

返回:

worker the new Worker

nextWorker

public E nextWorker()

从接口复制的说明: WorkerPool

Return the next Worker to use

指定者:

nextWorker 在接口中 WorkerPool<E extends org.jboss.netty.channel.socket.nio.AbstractNioWorker>

返回:

worker

rebuildSelectors

public void rebuildSelectors()

从接口复制的说明: NioSelectorPool

Replaces the current Selectors of the Bosses with new Selectors to work around the infamous epoll 100% CPU bug.

指定者:

rebuildSelectors 在接口中 NioSelectorPool

releaseExternalResources

public void releaseExternalResources()

从接口复制的说明: ExternalResourceReleasable

Releases the external resources that this object depends on. You should not call this method if the external resources (e.g. thread pool) are in use by other objects.

指定者:

releaseExternalResources 在接口中 ExternalResourceReleasable

shutdown

public void shutdown()

从接口复制的说明: NioSelectorPool

Shutdown the NioSelectorPool and all internal created resources

指定者:

shutdown 在接口中 NioSelectorPool