Fix bug 834

Andreas-Bur · Andreas-Bur · commit 26e49d7e427f · 2019-01-30T22:37:34.000+01:00
diff --git a/src/main/java/org/java_websocket/server/WebSocketServer.java b/src/main/java/org/java_websocket/server/WebSocketServer.java
@@ -211,7 +211,6 @@ public WebSocketServer( InetSocketAddress address , int decodercount , List<Draf
 		for( int i = 0 ; i < decodercount ; i++ ) {
 			WebSocketWorker ex = new WebSocketWorker();
 			decoders.add( ex );
-			ex.start();
 		}
 	}
 
@@ -229,6 +228,10 @@ public void start() {
 		if( selectorthread != null )
 			throw new IllegalStateException( getClass().getName() + " can only be started once." );
 		new Thread( this ).start();
+
+		for( WebSocketWorker ex : decoders ){
+			ex.start();
+		}
 	}
 
 	/**

Original file line number	Diff line number	Diff line change
`@@ -211,7 +211,6 @@ public WebSocketServer( InetSocketAddress address , int decodercount , List<Draf`
`211`	`211`	`for( int i = 0 ; i < decodercount ; i++ ) {`
`212`	`212`	`WebSocketWorker ex = new WebSocketWorker();`
`213`	`213`	`decoders.add( ex );`
`214`		`- ex.start();`
`215`	`214`	`}`
`216`	`215`	`}`
`217`	`216`
`@@ -229,6 +228,10 @@ public void start() {`
`229`	`228`	`if( selectorthread != null )`
`230`	`229`	`throw new IllegalStateException( getClass().getName() + " can only be started once." );`
`231`	`230`	`new Thread( this ).start();`
	`231`	`+`
	`232`	`+ for( WebSocketWorker ex : decoders ){`
	`233`	`+ ex.start();`
	`234`	`+ }`
`232`	`235`	`}`
`233`	`236`
`234`	`237`	`/**`