Remove uses of unbounded queues

Author: PhilipRoman

src/main/java/org/java_websocket/WebSocketImpl.java

@@ -35,7 +35,7 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ArrayBlockingQueue;
 import javax.net.ssl.SSLSession;
 import org.java_websocket.drafts.Draft;
 import org.java_websocket.drafts.Draft_6455;
@@ -203,8 +203,8 @@ public WebSocketImpl(WebSocketListener listener, Draft draft) {
     if (listener == null || (draft == null && role == Role.SERVER)) {
       throw new IllegalArgumentException("parameters must not be null");
     }
-    this.outQueue = new LinkedBlockingQueue<>();
-    inQueue = new LinkedBlockingQueue<>();
+    this.outQueue = new ArrayBlockingQueue<>(4096);
+    inQueue = new ArrayBlockingQueue<>(4096);
     this.wsl = listener;
     this.role = Role.CLIENT;
     if (draft != null) {
@@ -737,7 +737,11 @@ private void write(ByteBuffer buf) {
     log.trace("write({}): {}", buf.remaining(),
         buf.remaining() > 1000 ? "too big to display" : new String(buf.array()));
 
-    outQueue.add(buf);
+    try {
+      outQueue.put(buf);
+    } catch (InterruptedException e) {
+      throw new RuntimeException(e);
+    }
     wsl.onWriteDemand(this);
   }
 

src/main/java/org/java_websocket/server/WebSocketServer.java

@@ -245,10 +245,10 @@ public WebSocketServer(InetSocketAddress address, int decodercount, List<Draft>
     this.connections = connectionscontainer;
     setTcpNoDelay(false);
     setReuseAddr(false);
-    iqueue = new LinkedList<>();
+    iqueue = new ArrayDeque<>();
 
     decoders = new ArrayList<>(decodercount);
-    buffers = new LinkedBlockingQueue<>();
+    buffers = new LinkedBlockingQueue<>(4096);
     for (int i = 0; i < decodercount; i++) {
       WebSocketWorker ex = new WebSocketWorker();
       decoders.add(ex);
@@ -1111,7 +1111,7 @@ public class WebSocketWorker extends Thread {
     private BlockingQueue<WebSocketImpl> iqueue;
 
     public WebSocketWorker() {
-      iqueue = new LinkedBlockingQueue<>();
+      iqueue = new LinkedBlockingQueue<>(4096);
       setName("WebSocketWorker-" + getId());
       setUncaughtExceptionHandler(new UncaughtExceptionHandler() {
         @Override