From 848a30b2db3033adbb6b20782e7ce56a9ce44cf3 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Sat, 12 May 2018 14:35:34 +0800
Subject: [PATCH]

---
 src/org/redkale/source/PoolTcpSource.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/org/redkale/source/PoolTcpSource.java b/src/org/redkale/source/PoolTcpSource.java
index ab561be39..055c8b02f 100644
--- a/src/org/redkale/source/PoolTcpSource.java
+++ b/src/org/redkale/source/PoolTcpSource.java
@@ -102,7 +102,7 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
             return future;
         }
         AsyncConnection conn0 = connQueue.poll();
-        if (conn0 != null) {
+        if (conn0 != null && conn0.isOpen()) {
             cycleCounter.incrementAndGet();
             usingCounter.incrementAndGet();
             return CompletableFuture.completedFuture(conn0);
@@ -115,7 +115,7 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
                     return null;
                 }
             }, executor).thenCompose((conn2) -> {
-                if (conn2 != null) {
+                if (conn2 != null && conn2.isOpen()) {
                     cycleCounter.incrementAndGet();
                     return CompletableFuture.completedFuture(conn2);
                 }