public abstract class ClientAbstractIOSelector extends Thread implements IOSelector
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
protected boolean |
live |
protected ILogger |
logger |
protected Selector |
selector |
protected Queue<Runnable> |
selectorQueue |
protected int |
waitTime |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Modifier | Constructor and Description |
---|---|
protected |
ClientAbstractIOSelector(ThreadGroup threadGroup,
String threadName) |
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() |
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
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
start
protected final ILogger logger
protected final int waitTime
protected final Selector selector
protected boolean live
protected ClientAbstractIOSelector(ThreadGroup threadGroup, String threadName)
public Selector getSelector()
getSelector
in interface IOSelector
public void addTask(Runnable runnable)
addTask
in interface IOSelector
public void wakeup()
wakeup
in interface IOSelector
public void shutdown()
shutdown
in interface IOSelector
public void awaitShutdown()
awaitShutdown
in interface IOSelector
protected abstract void handleSelectionKey(SelectionKey sk)
Copyright © 2014 Hazelcast, Inc.. All rights reserved.