Merge pull request TooTallNate#489 from marci4/master

marci4 · web-flow · commit 143f2fbc55c9 · 2017-05-28T22:30:48.000+02:00
Possibility to override worker thread allocation logic in WebSocketSe…
diff --git a/src/main/java/org/java_websocket/server/WebSocketServer.java b/src/main/java/org/java_websocket/server/WebSocketServer.java
@@ -73,7 +73,7 @@ public abstract class WebSocketServer extends AbstractWebSocket implements Runna
 
 	private final AtomicBoolean isclosed = new AtomicBoolean( false );
 
-	private List<WebSocketWorker> decoders;
+	protected List<WebSocketWorker> decoders;
 
 	private List<WebSocketImpl> iqueue;
 	private BlockingQueue<ByteBuffer> buffers;
@@ -470,7 +470,7 @@ public ByteBuffer createBuffer(){
 		return ByteBuffer.allocate( WebSocketImpl.RCVBUF );
 	}
 
-	private void queue( WebSocketImpl ws ) throws InterruptedException{
+	protected void queue( WebSocketImpl ws ) throws InterruptedException{
 		if( ws.workerThread == null ){
 			ws.workerThread = decoders.get( queueinvokes % decoders.size() );
 			queueinvokes++;

-Original file line number
+Diff line change
 privatefinalAtomicBooleanisclosed = newAtomicBoolean( false );
 -privateList<WebSocketWorker> decoders;
 +protectedList<WebSocketWorker> decoders;
 privateList<WebSocketImpl> iqueue;
 privateBlockingQueue<ByteBuffer> buffers;
 returnByteBuffer.allocate( WebSocketImpl.RCVBUF );
+ }
 -privatevoidqueue( WebSocketImplws ) throwsInterruptedException{
 +protectedvoidqueue( WebSocketImplws ) throwsInterruptedException{
 if( ws.workerThread == null ){
 ws.workerThread = decoders.get( queueinvokes % decoders.size() );
 queueinvokes++;