Added protected methods to customize client thread names.

closes TooTallNate#1421

Author: NathanSweet

src/main/java/org/java_websocket/AbstractWebSocket.java

@@ -201,7 +201,7 @@ protected void startConnectionLostTimer() {
   private void restartConnectionLostTimer() {
     cancelConnectionLostTimer();
     connectionLostCheckerService = Executors
-        .newSingleThreadScheduledExecutor(new NamedThreadFactory("connectionLostChecker", daemon));
+        .newSingleThreadScheduledExecutor(new NamedThreadFactory(connectionLostThreadPrefix(), daemon));
     Runnable connectionLostChecker = new Runnable() {
 
       /**
@@ -233,6 +233,10 @@ public void run() {
             TimeUnit.NANOSECONDS);
   }
 
+  protected String connectionLostThreadPrefix () {
+    return "connectionLostChecker";
+  }
+
   /**
    * Send a ping to the endpoint or close the connection since the other endpoint did not respond
    * with a ping

src/main/java/org/java_websocket/client/WebSocketClient.java

@@ -380,10 +380,18 @@ public void connect() {
     }
     connectReadThread = new Thread(this);
     connectReadThread.setDaemon(isDaemon());
-    connectReadThread.setName("WebSocketConnectReadThread-" + connectReadThread.getId());
+    connectReadThread.setName(connectReadThreadName(connectReadThread.getId()));
     connectReadThread.start();
   }
 
+  protected String connectReadThreadName (long threadId) {
+    return "WebSocketConnectReadThread-" + threadId;
+  }
+
+  protected String writeThreadName (long threadId) {
+	  return "WebSocketWriteThread-" + threadId;
+  }
+
   /**
    * Same as <code>connect</code> but blocks until the websocket connected or failed to do so.<br>
    *
@@ -819,7 +827,7 @@ private class WebsocketWriteThread implements Runnable {
 
     @Override
     public void run() {
-      Thread.currentThread().setName("WebSocketWriteThread-" + Thread.currentThread().getId());
+      Thread.currentThread().setName(writeThreadName(Thread.currentThread().getId()));
       try {
         runWriteData();
       } catch (IOException e) {