Class

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: INNER | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

com.newstep.solid.netio.niowrapper

Class SelectorThread

+--com.newstep.solid.netio.niowrapper.SelectorThread

All Implemented Interfaces:
Runnable

public class SelectorThread

A thread that wraps a java.nio.channels.Selector and services selected keys.
getStartStopLatch MUST be invoked prior to starting this thread. The returned
CountDownLatch may be used to await for thread's startup.

Kernel Association Association Link

to Interface SelectorListener

Client navigability:

Supplier cardinality:

Supplier navigability:

Supplier visibility:

com.newstep.solid.netio.niowrapper.SelectorListener

Field Summary
CountDownLatch	startStopLatch
protected final static String	className
protected static Logger	logger
private boolean	running
private Selector	selector
private CountDownLatch	startStopLatch
private ReentrantLock	taskLock
private ArrayList	tasks

Constructor Summary
public void	SelectorThread(String name)

Method Summary
public void	addChannelInterest(SelectableChannel channel, Integer interest)
public void	deregisterChannel(SelectableChannel channel)
public CountDownLatch	getStartStopLatch()
public void	registerChannel(SelectableChannel channel, Integer interest, SelectorListener listener)
public void	removeChannelInterest(SelectableChannel channel, Integer interest)
public void	run()
private void	scheduleChannelDeregistration(SelectableChannel channel)
private void	scheduleChannelRegistration(SelectableChannel channel, Integer interest, SelectorListener listener)
private void	scheduleKeysUpdate(SelectionKey sKey, Integer newInterest)
public void	stopSelector()
protected void	updateKeys(SelectionKey sKey, Integer newInterest)

protected final static String className

protected static Logger logger

private boolean running

private Selector selector

private CountDownLatch startStopLatch

CountDownLatch startStopLatch

private ReentrantLock taskLock

private ArrayList tasks

com.newstep.solid.netio.niowrapper.SelectorListener

public void SelectorThread (String name)

public void addChannelInterest (SelectableChannel channel, Integer interest)

public void deregisterChannel (SelectableChannel channel)

public CountDownLatch getStartStopLatch ()

This operation MUST be invoked before starting the thread. The returned
latch can be used to await for the thread to start or exit after invoking
stopSelector method.

countDownLatch to await on while the trhead starts or exits