From 13ef219ab163e08244b1e4295f44536d04deeb57 Mon Sep 17 00:00:00 2001 From: Redkale Date: Tue, 3 Jan 2023 18:52:42 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BB=89=E5=A9=9A=E6=AB=8EioThread=E6=BE=B6?= =?UTF-8?q?=E6=B0=AB=E7=B6=91=E6=B5=A0=EF=BD=87=E7=88=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/org/redkale/net/AsyncIOGroup.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/src/main/java/org/redkale/net/AsyncIOGroup.java b/src/main/java/org/redkale/net/AsyncIOGroup.java index 1cbfc4546..7b192402f 100644 --- a/src/main/java/org/redkale/net/AsyncIOGroup.java +++ b/src/main/java/org/redkale/net/AsyncIOGroup.java @@ -85,8 +85,6 @@ public class AsyncIOGroup extends AsyncGroup { ObjectPool unsafeReadBufferPool = ObjectPool.createUnsafePool(safeBufferPool, safeBufferPool.getCreatCounter(), safeBufferPool.getCycleCounter(), 512, safeBufferPool.getCreator(), safeBufferPool.getPrepare(), safeBufferPool.getRecycler()); String name = threadPrefixName + "-" + (i >= 9 ? (i + 1) : ("0" + (i + 1))); - this.ioReadThreads[i] = client ? new ClientIOThread(name, i, threads, workExecutor, Selector.open(), unsafeReadBufferPool, safeBufferPool) - : new AsyncIOThread(name, i, threads, workExecutor, Selector.open(), unsafeReadBufferPool, safeBufferPool); if (client) { this.ioReadThreads[i] = new ClientIOThread(name, i, threads, workExecutor, Selector.open(), unsafeReadBufferPool, safeBufferPool); this.ioWriteThreads[i] = this.ioReadThreads[i];