From 34ae2d38c5538fc310b05f92666102c9709d1af9 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Fri, 15 Nov 2019 15:54:34 +0800
Subject: [PATCH]

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

diff --git a/src/org/redkale/source/PoolTcpSource.java b/src/org/redkale/source/PoolTcpSource.java
index bbbe92464..828c05904 100644
--- a/src/org/redkale/source/PoolTcpSource.java
+++ b/src/org/redkale/source/PoolTcpSource.java
@@ -66,6 +66,8 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
         try {
             if (connQueue.isEmpty()) return;
             long time = System.currentTimeMillis() - 30 * 1000;
+            AsyncConnection first = connQueue.peek();
+            if (first == null || first.getLastReadTime() >= time || first.getLastWriteTime() >= time) return;
             pollAsync().whenComplete((conn, e) -> {
                 if (e != null) return;
                 if (conn.getLastReadTime() >= time || conn.getLastWriteTime() >= time) {//半分钟内已经用过