This commit is contained in:
@@ -5,10 +5,8 @@
|
|||||||
*/
|
*/
|
||||||
package org.redkale.net;
|
package org.redkale.net;
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.net.*;
|
import java.net.*;
|
||||||
import java.nio.*;
|
import java.nio.*;
|
||||||
import java.nio.channels.AsynchronousChannelGroup;
|
|
||||||
import java.nio.charset.*;
|
import java.nio.charset.*;
|
||||||
import java.util.concurrent.*;
|
import java.util.concurrent.*;
|
||||||
import java.util.function.*;
|
import java.util.function.*;
|
||||||
@@ -145,10 +143,6 @@ public class Context {
|
|||||||
return executor.submit(r);
|
return executor.submit(r);
|
||||||
}
|
}
|
||||||
|
|
||||||
public AsynchronousChannelGroup createAsynchronousChannelGroup() throws IOException {
|
|
||||||
return AsynchronousChannelGroup.withThreadPool(executor);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void runAsync(Runnable r) {
|
public void runAsync(Runnable r) {
|
||||||
executor.execute(r);
|
executor.execute(r);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user