Revert "Atomic processing of create/remove of keepalive thread"

This reverts commit 4680cb8 (caused shyiko#321).

Author: shyiko

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java

@@ -164,7 +164,6 @@ public X509Certificate[] getAcceptedIssuers() {
     private volatile ExecutorService keepAliveThreadExecutor;
 
     private final Lock connectLock = new ReentrantLock();
-    private final Lock keepAliveThreadExecutorLock = new ReentrantLock();
 
     /**
      * Alias for BinaryLogClient("localhost", 3306, <no schema> = null, username, password).
@@ -771,8 +770,6 @@ public Thread newThread(Runnable runnable) {
                     return newNamedThread(runnable, "blc-keepalive-" + hostname + ":" + port);
                 }
             });
-        try {
-            keepAliveThreadExecutorLock.lock();
         threadExecutor.submit(new Runnable() {
             @Override
             public void run() {
@@ -813,9 +810,6 @@ public void run() {
             }
         });
         keepAliveThreadExecutor = threadExecutor;
-        } finally {
-            keepAliveThreadExecutorLock.unlock();
-        }
     }
 
     private Thread newNamedThread(Runnable runnable, String threadName) {
@@ -825,12 +819,7 @@ private Thread newNamedThread(Runnable runnable, String threadName) {
     }
 
     boolean isKeepAliveThreadRunning() {
-        try {
-            keepAliveThreadExecutorLock.lock();
         return keepAliveThreadExecutor != null && !keepAliveThreadExecutor.isShutdown();
-        } finally {
-            keepAliveThreadExecutorLock.unlock();
-        }
     }
 
     /**
@@ -1180,8 +1169,6 @@ public void disconnect() throws IOException {
     }
 
     private void terminateKeepAliveThread() {
-        try {
-            keepAliveThreadExecutorLock.lock();
         ExecutorService keepAliveThreadExecutor = this.keepAliveThreadExecutor;
         if (keepAliveThreadExecutor == null) {
             return;
@@ -1191,9 +1178,6 @@ private void terminateKeepAliveThread() {
             Long.MAX_VALUE, TimeUnit.NANOSECONDS)) {
             // ignore
         }
-        } finally {
-            keepAliveThreadExecutorLock.unlock();
-        }
     }
 
     private static boolean awaitTerminationInterruptibly(ExecutorService executorService, long timeout, TimeUnit unit) {