Package org.java_websocket.server
Class WebSocketServer.WebSocketWorker
- java.lang.Object
-
- java.lang.Thread
-
- org.java_websocket.server.WebSocketServer.WebSocketWorker
-
- All Implemented Interfaces:
java.lang.Runnable
- Enclosing class:
- WebSocketServer
public class WebSocketServer.WebSocketWorker extends java.lang.Thread
This class is used to process incoming data
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.BlockingQueue<WebSocketImpl>
iqueue
-
Constructor Summary
Constructors Constructor Description WebSocketWorker()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
doDecode(WebSocketImpl ws, java.nio.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, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Field Detail
-
iqueue
private java.util.concurrent.BlockingQueue<WebSocketImpl> iqueue
-
-
Method Detail
-
put
public void put(WebSocketImpl ws) throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
doDecode
private void doDecode(WebSocketImpl ws, java.nio.ByteBuffer buf) throws java.lang.InterruptedException
call ws.decode on the byteBuffer- Parameters:
ws
- the Websocketbuf
- the buffer to decode to- Throws:
java.lang.InterruptedException
- thrown by pushBuffer
-
-