protected static class NioBlockingSelector.BlockPoller extends Thread
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
protected ConcurrentLinkedQueue<Runnable> |
events |
protected boolean |
run |
protected Selector |
selector |
protected AtomicInteger |
wakeupCounter |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Modifier | Constructor and Description |
---|---|
protected |
NioBlockingSelector.BlockPoller() |
Modifier and Type | Method and Description |
---|---|
void |
add(NioEndpoint.KeyAttachment key,
int ops,
NioBlockingSelector.KeyReference ref) |
void |
cancel(SelectionKey sk,
NioEndpoint.KeyAttachment key,
int ops) |
void |
cancelKey(SelectionKey key) |
void |
countDown(CountDownLatch latch) |
void |
disable() |
boolean |
events() |
void |
remove(NioEndpoint.KeyAttachment key,
int ops) |
void |
run() |
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
protected volatile boolean run
protected Selector selector
protected ConcurrentLinkedQueue<Runnable> events
protected AtomicInteger wakeupCounter
public void disable()
public void cancelKey(SelectionKey key)
public void wakeup()
public void cancel(SelectionKey sk, NioEndpoint.KeyAttachment key, int ops)
public void add(NioEndpoint.KeyAttachment key, int ops, NioBlockingSelector.KeyReference ref)
public void remove(NioEndpoint.KeyAttachment key, int ops)
public boolean events()
public void countDown(CountDownLatch latch)
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.