org.eclipse.jetty.io

Class SelectorManager.ManagedSelector

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.io.SelectorManager.ManagedSelector

All Implemented Interfaces:

Runnable, Dumpable, LifeCycle

Enclosing class:

SelectorManager

public class SelectorManager.ManagedSelector
extends AbstractLifeCycle
implements Runnable, Dumpable

SelectorManager.ManagedSelector wraps a Selector simplifying non-blocking operations on channels.

SelectorManager.ManagedSelector runs the select loop, which waits on Selector.select() until events happen for registered channels. When events happen, it notifies the EndPoint associated with the channel.

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

LifeCycle.Listener

Field Summary

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Constructor Summary

Constructors

Constructor and Description
SelectorManager.ManagedSelector(int id)

Method Summary

Methods

Modifier and Type	Method and Description
void	destroyEndPoint(EndPoint endPoint)
protected void	doStart()
protected void	doStop()
String	dump()
void	dump(Appendable out, String indent)
void	dumpKeysState(List<Object> dumps)
boolean	isSelectorThread()
void	run()
protected void	runChange(Runnable change)
void	select() Process changes and waits on Selector.select().
void	submit(Runnable change) Submits a change to be executed in the selector thread.
String	toString()
void	updateKey(Runnable update) Submit a task to update a selector key.
void	wakeup()

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, setStopTimeout, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

SelectorManager.ManagedSelector

public SelectorManager.ManagedSelector(int id)

Method Detail

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class AbstractLifeCycle

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class AbstractLifeCycle

Throws:

Exception

updateKey

public void updateKey(Runnable update)

Submit a task to update a selector key. If the System property SelectorManager.SUBMIT_KEY_UPDATES is set true (default is false), the task is passed to submit(Runnable). Otherwise it is run immediately and the selector woken up if need be.

Parameters:

update - the update to a key

submit

public void submit(Runnable change)

Submits a change to be executed in the selector thread.

Changes may be submitted from any thread, and the selector thread woken up (if necessary) to execute the change.

Parameters:

change - the change to submit

runChange

protected void runChange(Runnable change)

run

public void run()

Specified by:

run in interface Runnable

select

public void select()

Process changes and waits on Selector.select().

See Also:

submit(Runnable)

wakeup

public void wakeup()

isSelectorThread

public boolean isSelectorThread()

destroyEndPoint

public void destroyEndPoint(EndPoint endPoint)

dump

public String dump()

Specified by:

dump in interface Dumpable

dump

public void dump(Appendable out,
        String indent)
          throws IOException

Specified by:

dump in interface Dumpable

Throws:

IOException

dumpKeysState

public void dumpKeysState(List<Object> dumps)

toString

public String toString()

Overrides:

toString in class Object