org.fusesource.hawtdispatch.internal

Class NioManager

java.lang.Object

org.fusesource.hawtdispatch.internal.NioManager

public class NioManager
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	NioManager.SelectStrategy Handles doing a select on a selector.
(package private) class	NioManager.WorkAroundSelectSpin Workaround for the selector spin bug.

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.atomic.AtomicInteger	registeredKeys
protected int	selectCounter
protected boolean	selecting
private java.nio.channels.Selector	selector
(package private) NioManager.SelectStrategy	selectStrategy Set the "hawtdispatch.workaround-select-spin" System property to "true" if your seeing the 100% CPU usage in the Selector.select() call.
private boolean	TRACE
private java.util.LinkedList<java.lang.String>	traces
protected java.util.concurrent.atomic.AtomicInteger	wakeupCounter

Constructor Summary

Constructors

Constructor and Description
NioManager()

Method Summary

Modifier and Type	Method and Description
void	cancel(java.nio.channels.SelectionKey key)
int	getRegisteredKeyCount()
private int	processSelected()
NioAttachment	register(java.nio.channels.SelectableChannel channel, int interestOps)
int	select(long timeout) Selects ready sources, potentially blocking.
void	shutdown()
protected void	trace(java.lang.String str, java.lang.Object... args)
boolean	wakeupIfSelecting()

Methods inherited from class java.lang.Object

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

Field Detail

selectStrategy

final NioManager.SelectStrategy selectStrategy

Set the "hawtdispatch.workaround-select-spin" System property to "true" if your seeing the 100% CPU usage in the Selector.select() call. This enables a workaround for a JVM/OS bug documented at http://bugs.sun.com/view_bug.do?bug_id=6693490

selector

private java.nio.channels.Selector selector

wakeupCounter

protected final java.util.concurrent.atomic.AtomicInteger wakeupCounter

selectCounter

protected volatile int selectCounter

registeredKeys

private final java.util.concurrent.atomic.AtomicInteger registeredKeys

selecting

protected volatile boolean selecting

TRACE

private final boolean TRACE

See Also:

Constant Field Values

traces

private final java.util.LinkedList<java.lang.String> traces

Constructor Detail

NioManager

public NioManager()
           throws java.io.IOException

Throws:

java.io.IOException

Method Detail

wakeupIfSelecting

public boolean wakeupIfSelecting()

Returns:

true if the selector was selecting..

select

public int select(long timeout)
           throws java.io.IOException

Selects ready sources, potentially blocking. If wakeup is called during select the method will return.

Parameters:

timeout - A negative value cause the select to block until a source is ready, 0 will do a non blocking select. Otherwise the select will block up to timeout in milliseconds waiting for a source to become ready.

Throws:

java.io.IOException

processSelected

private int processSelected()

shutdown

public void shutdown()
              throws java.io.IOException

Throws:

java.io.IOException

trace

protected void trace(java.lang.String str,
                     java.lang.Object... args)

register

public NioAttachment register(java.nio.channels.SelectableChannel channel,
                              int interestOps)
                       throws java.nio.channels.ClosedChannelException

Throws:

java.nio.channels.ClosedChannelException

getRegisteredKeyCount

public int getRegisteredKeyCount()

cancel

public void cancel(java.nio.channels.SelectionKey key)