java.lang.Runnable
protected static class NioBlockingSelector.BlockPoller
extends java.lang.Thread
Modifier and Type | Class | Description |
---|---|---|
static class |
NioBlockingSelector.BlockPoller.RunnableCancel |
Modifier and Type | Field | Description |
---|---|---|
protected SynchronizedQueue<java.lang.Runnable> |
events |
|
protected boolean |
run |
|
protected java.nio.channels.Selector |
selector |
|
protected java.util.concurrent.atomic.AtomicInteger |
wakeupCounter |
Modifier | Constructor | Description |
---|---|---|
protected |
BlockPoller() |
Modifier and Type | Method | Description |
---|---|---|
void |
add(NioEndpoint.NioSocketWrapper key,
int ops,
NioBlockingSelector.KeyReference ref) |
|
void |
cancel(java.nio.channels.SelectionKey sk,
NioEndpoint.NioSocketWrapper key,
int ops) |
|
void |
cancelKey(java.nio.channels.SelectionKey key) |
|
void |
countDown(java.util.concurrent.CountDownLatch latch) |
|
void |
disable() |
|
boolean |
events() |
|
void |
remove(NioEndpoint.NioSocketWrapper key,
int ops) |
|
void |
run() |
|
void |
wakeup() |
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
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, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
protected volatile boolean run
protected java.nio.channels.Selector selector
protected final SynchronizedQueue<java.lang.Runnable> events
protected final java.util.concurrent.atomic.AtomicInteger wakeupCounter
public void disable()
public void cancelKey(java.nio.channels.SelectionKey key)
public void wakeup()
public void cancel(java.nio.channels.SelectionKey sk, NioEndpoint.NioSocketWrapper key, int ops)
public void add(NioEndpoint.NioSocketWrapper key, int ops, NioBlockingSelector.KeyReference ref)
public void remove(NioEndpoint.NioSocketWrapper key, int ops)
public boolean events()
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public void countDown(java.util.concurrent.CountDownLatch latch)
Copyright © 2000-2019 Apache Software Foundation. All Rights Reserved.