From 511a966ce52d3ae026c2b752f8ce2d60069d0cf3 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Fri, 13 Jul 2018 23:11:36 +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 826f0fdce..53e76d4b7 100644
--- a/src/org/redkale/source/PoolTcpSource.java
+++ b/src/org/redkale/source/PoolTcpSource.java
@@ -39,7 +39,7 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
         this.bufferPool = bufferPool;
         this.executor = executor;
         try {
-            this.group = AsynchronousChannelGroup.withCachedThreadPool(executor, executor.getCorePoolSize());
+            this.group = AsynchronousChannelGroup.withFixedThreadPool(executor.getCorePoolSize(), executor.getThreadFactory());
         } catch (IOException e) {
             throw new RuntimeException(e);
         }
@@ -121,7 +121,7 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
                     t.printStackTrace();
                     return null;
                 }
-            }).thenCompose((conn2) -> {
+            }, executor).thenCompose((conn2) -> {
                 if (conn2 != null && conn2.isOpen()) {
                     cycleCounter.incrementAndGet();
                     usingCounter.incrementAndGet();