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); }