Package org.java_websocket.server
Class WebSocketServer.WebSocketWorker
java.lang.Object
java.lang.Thread
org.java_websocket.server.WebSocketServer.WebSocketWorker
- All Implemented Interfaces:
Runnable
- Enclosing class:
WebSocketServer
This class is used to process incoming data
-
Nested Class Summary
Nested classes/interfaces inherited from class java.lang.Thread
Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler
-
Field Summary
FieldsFields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate void
doDecode
(WebSocketImpl ws, ByteBuffer buf) call ws.decode on the byteBuffervoid
put
(WebSocketImpl ws) void
run()
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, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, toString, yield
-
Field Details
-
iqueue
-
-
Constructor Details
-
WebSocketWorker
public WebSocketWorker()
-
-
Method Details
-
put
- Throws:
InterruptedException
-
run
public void run() -
doDecode
call ws.decode on the byteBuffer- Parameters:
ws
- the Websocketbuf
- the buffer to decode to- Throws:
InterruptedException
- thrown by pushBuffer
-