com.hazelcast.client.connection.nio

Class ClientAbstractIOSelector

java.lang.Object

java.lang.Thread

com.hazelcast.client.connection.nio.ClientAbstractIOSelector

All Implemented Interfaces:

IOSelector, Runnable

Direct Known Subclasses:

ClientInSelectorImpl, ClientOutSelectorImpl

public abstract class ClientAbstractIOSelector
extends Thread
implements IOSelector

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	live
protected ILogger	logger
protected Selector	selector
protected Queue<Runnable>	selectorQueue
protected int	waitTime

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ClientAbstractIOSelector(ThreadGroup threadGroup, String threadName)

Method Summary

Modifier and Type	Method and Description
void	addTask(Runnable runnable)
void	awaitShutdown()
Selector	getSelector()
protected abstract void	handleSelectionKey(SelectionKey sk)
void	run()
void	shutdown()
void	wakeup()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.nio.IOSelector

start

Field Detail

logger

protected final ILogger logger

selectorQueue

protected final Queue<Runnable> selectorQueue

waitTime

protected final int waitTime

selector

protected final Selector selector

live

protected boolean live

Constructor Detail

ClientAbstractIOSelector

protected ClientAbstractIOSelector(ThreadGroup threadGroup,
                                   String threadName)

Method Detail

getSelector

public Selector getSelector()

Specified by:

getSelector in interface IOSelector

addTask

public void addTask(Runnable runnable)

Specified by:

addTask in interface IOSelector

wakeup

public void wakeup()

Specified by:

wakeup in interface IOSelector

shutdown

public void shutdown()

Specified by:

shutdown in interface IOSelector

awaitShutdown

public void awaitShutdown()

Specified by:

awaitShutdown in interface IOSelector

run

public final void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

handleSelectionKey

protected abstract void handleSelectionKey(SelectionKey sk)