Package one.nio.net

Class JavaSelector

java.lang.Object

one.nio.net.Selector

one.nio.net.JavaSelector

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Iterable<Session>

final class JavaSelector
extends Selector

Field Summary

Fields

Modifier and Type	Field	Description
private java.nio.channels.Selector	impl
private long	lastWakeupTime
private static org.slf4j.Logger	log
private java.util.concurrent.ConcurrentLinkedQueue<Session>	pendingSessions

Constructor Summary

Constructors

Constructor	Description
JavaSelector()

Method Summary

Modifier and Type	Method	Description
void	close()
void	disable(Session session)
void	enable(Session session)
boolean	isOpen()
java.util.Iterator<Session>	iterator()
private static java.util.Iterator<Session>	iteratorFor(java.util.Set<java.nio.channels.SelectionKey> keys)
long	lastWakeupTime()
void	listen(Session session, int events)
void	register(Session session)
private void	registerPendingSessions()
java.util.Iterator<Session>	select()
int	size()
void	unregister(Session session)

Methods inherited from class one.nio.net.Selector

create

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

log

private static final org.slf4j.Logger log

impl

private final java.nio.channels.Selector impl

pendingSessions

private final java.util.concurrent.ConcurrentLinkedQueue<Session> pendingSessions

lastWakeupTime

private long lastWakeupTime

Constructor Detail

JavaSelector

JavaSelector()
      throws java.io.IOException

Throws:

java.io.IOException

Method Detail

size

public final int size()

Specified by:

size in class Selector

isOpen

public boolean isOpen()

Specified by:

isOpen in class Selector

close

public final void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in class Selector

register

public final void register(Session session)

Specified by:

register in class Selector

unregister

public final void unregister(Session session)

Specified by:

unregister in class Selector

enable

public final void enable(Session session)

Specified by:

enable in class Selector

disable

public final void disable(Session session)

Specified by:

disable in class Selector

listen

public final void listen(Session session,
                         int events)

Specified by:

listen in class Selector

iterator

public final java.util.Iterator<Session> iterator()

Specified by:

iterator in interface java.lang.Iterable<Session>

Specified by:

iterator in class Selector

select

public final java.util.Iterator<Session> select()

Specified by:

select in class Selector

lastWakeupTime

public long lastWakeupTime()

Specified by:

lastWakeupTime in class Selector

registerPendingSessions

private void registerPendingSessions()
                              throws java.io.IOException

Throws:

java.io.IOException

iteratorFor

private static java.util.Iterator<Session> iteratorFor(java.util.Set<java.nio.channels.SelectionKey> keys)