diff --git a/src/main/java/org/jboss/netty/channel/socket/nio/NioClientSocketChannelFactory.java b/src/main/java/org/jboss/netty/channel/socket/nio/NioClientSocketChannelFactory.java index effffac269..3212654bfe 100644 --- a/src/main/java/org/jboss/netty/channel/socket/nio/NioClientSocketChannelFactory.java +++ b/src/main/java/org/jboss/netty/channel/socket/nio/NioClientSocketChannelFactory.java @@ -87,6 +87,15 @@ public class NioClientSocketChannelFactory implements ClientSocketChannelFactory private final WorkerPool workerPool; private final NioClientSocketPipelineSink sink; + /** + * Creates a new {@link NioClientSocketChannelFactory} which uses {@link Executors#newCachedThreadPool()} for the worker and boss executors. + * + * See {@link #NioClientSocketChannelFactory(Executor, Executor)} + */ + public NioClientSocketChannelFactory() { + this(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()); + } + /** * Creates a new instance. Calling this constructor is same with calling * {@link #NioClientSocketChannelFactory(Executor, Executor, int, int)} with diff --git a/src/main/java/org/jboss/netty/channel/socket/nio/NioDatagramChannelFactory.java b/src/main/java/org/jboss/netty/channel/socket/nio/NioDatagramChannelFactory.java index c8b83d7298..6ea6044288 100644 --- a/src/main/java/org/jboss/netty/channel/socket/nio/NioDatagramChannelFactory.java +++ b/src/main/java/org/jboss/netty/channel/socket/nio/NioDatagramChannelFactory.java @@ -79,6 +79,15 @@ public class NioDatagramChannelFactory implements DatagramChannelFactory { private final NioDatagramPipelineSink sink; private final WorkerPool workerPool; + /** + * Create a new {@link NioDatagramChannelFactory} with a {@link Executors#newCachedThreadPool()}. + * + * See {@link #NioDatagramChannelFactory(Executor)} + */ + public NioDatagramChannelFactory() { + this(Executors.newCachedThreadPool()); + } + /** * Creates a new instance. Calling this constructor is same with calling * {@link #NioDatagramChannelFactory(Executor, int)} with 2 * the number of diff --git a/src/main/java/org/jboss/netty/channel/socket/nio/NioServerSocketChannelFactory.java b/src/main/java/org/jboss/netty/channel/socket/nio/NioServerSocketChannelFactory.java index dafbc6cfc7..28109b1aec 100644 --- a/src/main/java/org/jboss/netty/channel/socket/nio/NioServerSocketChannelFactory.java +++ b/src/main/java/org/jboss/netty/channel/socket/nio/NioServerSocketChannelFactory.java @@ -89,6 +89,15 @@ public class NioServerSocketChannelFactory implements ServerSocketChannelFactory private final WorkerPool workerPool; private final ChannelSink sink; + /** + * Create a new {@link NioServerSocketChannelFactory} using {@link Executors#newCachedThreadPool()} for the boss and worker. + * + * See {@link #NioServerSocketChannelFactory(Executor, Executor)} + */ + public NioServerSocketChannelFactory() { + this(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()); + } + /** * Creates a new instance. Calling this constructor is same with calling * {@link #NioServerSocketChannelFactory(Executor, Executor, int)} with 2 * diff --git a/src/main/java/org/jboss/netty/channel/socket/oio/OioClientSocketChannelFactory.java b/src/main/java/org/jboss/netty/channel/socket/oio/OioClientSocketChannelFactory.java index efb0de938e..75eeb485c3 100644 --- a/src/main/java/org/jboss/netty/channel/socket/oio/OioClientSocketChannelFactory.java +++ b/src/main/java/org/jboss/netty/channel/socket/oio/OioClientSocketChannelFactory.java @@ -16,6 +16,7 @@ package org.jboss.netty.channel.socket.oio; import java.util.concurrent.Executor; +import java.util.concurrent.Executors; import java.util.concurrent.RejectedExecutionException; import org.jboss.netty.channel.Channel; @@ -76,6 +77,15 @@ public class OioClientSocketChannelFactory implements ClientSocketChannelFactory private final Executor workerExecutor; final OioClientSocketPipelineSink sink; + /** + * Creates a new instance with a {@link Executors#newCachedThreadPool()} as worker executor. + * + * See {@link #OioClientSocketChannelFactory(Executor)} + */ + public OioClientSocketChannelFactory() { + this(Executors.newCachedThreadPool()); + } + /** * Creates a new instance. * diff --git a/src/main/java/org/jboss/netty/channel/socket/oio/OioServerSocketChannelFactory.java b/src/main/java/org/jboss/netty/channel/socket/oio/OioServerSocketChannelFactory.java index 169bc82328..11ce5803f5 100644 --- a/src/main/java/org/jboss/netty/channel/socket/oio/OioServerSocketChannelFactory.java +++ b/src/main/java/org/jboss/netty/channel/socket/oio/OioServerSocketChannelFactory.java @@ -16,6 +16,7 @@ package org.jboss.netty.channel.socket.oio; import java.util.concurrent.Executor; +import java.util.concurrent.Executors; import java.util.concurrent.RejectedExecutionException; import org.jboss.netty.channel.Channel; @@ -89,6 +90,15 @@ public class OioServerSocketChannelFactory implements ServerSocketChannelFactory private final Executor workerExecutor; private final ChannelSink sink; + /** + * Create a new {@link OioServerSocketChannelFactory} with a {@link Executors#newCachedThreadPool()} for the boss and worker executor. + * + * See {@link #OioServerSocketChannelFactory(Executor, Executor)} + */ + public OioServerSocketChannelFactory() { + this(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()); + } + /** * Creates a new instance. *