lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2018-05-12 14:35:34 +08:00
parent 350ece1533
commit 848a30b2db
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/org/redkale/source/PoolTcpSource.java
View File

@@ -102,7 +102,7 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
return future; return future;
} }
AsyncConnection conn0 = connQueue.poll(); AsyncConnection conn0 = connQueue.poll();
if (conn0 != null) { if (conn0 != null && conn0.isOpen()) {
cycleCounter.incrementAndGet(); cycleCounter.incrementAndGet();
usingCounter.incrementAndGet(); usingCounter.incrementAndGet();
return CompletableFuture.completedFuture(conn0); return CompletableFuture.completedFuture(conn0);
@@ -115,7 +115,7 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
return null; return null;
} }
}, executor).thenCompose((conn2) -> { }, executor).thenCompose((conn2) -> {
if (conn2 != null) { if (conn2 != null && conn2.isOpen()) {
cycleCounter.incrementAndGet(); cycleCounter.incrementAndGet();
return CompletableFuture.completedFuture(conn2); return CompletableFuture.completedFuture(conn2);
} }