Package one.nio.server.acceptor
Class MultiAcceptorThread
- java.lang.Object
-
- java.lang.Thread
-
- one.nio.server.acceptor.MultiAcceptorThread
-
- All Implemented Interfaces:
java.lang.Runnable
class MultiAcceptorThread extends java.lang.Thread
-
-
Field Summary
Fields Modifier and Type Field Description (package private) longacceptedSessionsprivate static org.slf4j.Loggerlogprivate static intMAX_ACCEPTED_PER_SOCKET(package private) longrejectedSessionsprivate Selectorselectorprivate Serverserver
-
Constructor Summary
Constructors Constructor Description MultiAcceptorThread(Server server)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) voidregister(MultiAcceptSession session)voidrun()(package private) voidshutdown()-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, 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, suspend, toString, yield
-
-
-
-
Field Detail
-
log
private static final org.slf4j.Logger log
-
MAX_ACCEPTED_PER_SOCKET
private static final int MAX_ACCEPTED_PER_SOCKET
- See Also:
- Constant Field Values
-
server
private final Server server
-
selector
private final Selector selector
-
acceptedSessions
volatile long acceptedSessions
-
rejectedSessions
volatile long rejectedSessions
-
-
Constructor Detail
-
MultiAcceptorThread
MultiAcceptorThread(Server server) throws java.io.IOException
- Throws:
java.io.IOException
-
-
Method Detail
-
register
void register(MultiAcceptSession session) throws java.io.IOException
- Throws:
java.io.IOException
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable- Overrides:
runin classjava.lang.Thread
-
shutdown
void shutdown()
-
-