com.gigaspaces.lrmi.nio.selector.handler

Class AbstractSelectorThread

java.lang.Object

com.j_spaces.kernel.ManagedRunnable

com.gigaspaces.lrmi.nio.selector.handler.AbstractSelectorThread

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

AcceptSelectorThread, ClientHandler, ReadSelectorThread, WriteSelectorThread

public abstract class AbstractSelectorThread
extends ManagedRunnable
implements Runnable

Provides a general selector logic.

Since:

6.0.4, 6.5

Author:

Guy Korland

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	_logger
protected Pivot	_pivot
protected Thread	ownerThread

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractSelectorThread(Pivot pivot)

Method Summary

Modifier and Type	Method and Description
protected void	cancelKey(SelectionKey key)
protected void	closeChannel(SocketChannel channel) Close a given channel
protected abstract void	enableSelectionKeys()
protected Selector	getSelector()
protected abstract void	handleConnection(SelectionKey key)
protected SelectionKey	register(SocketChannel channel, int requestOps)
void	run()
protected void	waitWhileFinish() This method will be invoked by requestShutdown().

Methods inherited from class com.j_spaces.kernel.ManagedRunnable

requestShutdown, shouldShutdown

Methods inherited from class java.lang.Object

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

Field Detail

_logger

protected static final org.slf4j.Logger _logger

_pivot

protected final Pivot _pivot

ownerThread

protected volatile Thread ownerThread

Constructor Detail

AbstractSelectorThread

protected AbstractSelectorThread(Pivot pivot)
                          throws IOException

Throws:

IOException

Method Detail

run

public void run()

Specified by:

run in interface Runnable

register

protected SelectionKey register(SocketChannel channel,
                                int requestOps)
                         throws ClosedChannelException

Throws:

ClosedChannelException

enableSelectionKeys

protected abstract void enableSelectionKeys()

handleConnection

protected abstract void handleConnection(SelectionKey key)
                                  throws IOException,
                                         InterruptedException

Throws:

IOException

InterruptedException

cancelKey

protected void cancelKey(SelectionKey key)

closeChannel

protected void closeChannel(SocketChannel channel)

Close a given channel

Parameters:

channel - target channel to close.

waitWhileFinish

protected void waitWhileFinish()

Description copied from class: ManagedRunnable

This method will be invoked by requestShutdown(). Request method will be block while waitWhileFinish() will not be finished.

Specified by:

waitWhileFinish in class ManagedRunnable

getSelector

protected Selector getSelector()