From 01e8649e2a468b1ccd60d3c3b1cf1fe3601d15de Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Mon, 13 Nov 2017 19:15:45 +0800 Subject: [PATCH] =?UTF-8?q?Context=E6=8F=90=E4=BE=9BcreateAsynchronousChan?= =?UTF-8?q?nelGroup=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/org/redkale/net/Context.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/org/redkale/net/Context.java b/src/org/redkale/net/Context.java index 3262134a3..86828c956 100644 --- a/src/org/redkale/net/Context.java +++ b/src/org/redkale/net/Context.java @@ -5,8 +5,10 @@ */ package org.redkale.net; +import java.io.IOException; import java.net.*; import java.nio.*; +import java.nio.channels.AsynchronousChannelGroup; import java.nio.charset.*; import java.util.concurrent.*; import java.util.function.*; @@ -107,6 +109,10 @@ public class Context { return executor.submit(r); } + public AsynchronousChannelGroup createAsynchronousChannelGroup() throws IOException { + return AsynchronousChannelGroup.withThreadPool(executor); + } + public void runAsync(Runnable r) { executor.execute(r); }