Package one.nio.net

Class JavaSelector

java.lang.Object

one.nio.net.Selector

one.nio.net.JavaSelector

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<Session>

final class JavaSelector
extends Selector

Field Summary

Fields

Modifier and Type	Field	Description
private final Selector	impl
private long	lastWakeupTime
private static final org.slf4j.Logger	log
private final ConcurrentLinkedQueue<Session>	pendingSessions

Constructor Summary

Constructors

Constructor	Description
JavaSelector()

Method Summary

Modifier and Type	Method	Description
final void	close()
final void	disable(Session session)
final void	enable(Session session)
boolean	isOpen()
final Iterator<Session>	iterator()
private static Iterator<Session>	iteratorFor(Set<SelectionKey> keys)
long	lastWakeupTime()
final void	listen(Session session, int events)
final void	register(Session session)
private void	registerPendingSessions()
final Iterator<Session>	select()
final int	size()
final 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 Details

log

private static final org.slf4j.Logger log

impl

private final Selector impl

pendingSessions

private final ConcurrentLinkedQueue<Session> pendingSessions

lastWakeupTime

private long lastWakeupTime

Constructor Details

JavaSelector

JavaSelector()
      throws IOException

Throws:

IOException

Method Details

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 AutoCloseable

Specified by:

close in interface 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 Iterator<Session> iterator()

Specified by:

iterator in interface Iterable<Session>

Specified by:

iterator in class Selector

select

public final Iterator<Session> select()

Specified by:

select in class Selector

lastWakeupTime

public long lastWakeupTime()

Specified by:

lastWakeupTime in class Selector

registerPendingSessions

private void registerPendingSessions()
                              throws IOException

Throws:

IOException

iteratorFor

private static Iterator<Session> iteratorFor(Set<SelectionKey> keys)