* Added missing constructor JavaDoc
* Fixed description of workerCount parameter
This commit is contained in:
parent
101124f8b8
commit
d96b633b5f
|
@ -120,7 +120,7 @@ public class NioClientSocketChannelFactory implements ClientSocketChannelFactory
|
||||||
* @param workerExecutor
|
* @param workerExecutor
|
||||||
* the {@link Executor} which will execute the I/O worker threads
|
* the {@link Executor} which will execute the I/O worker threads
|
||||||
* @param workerCount
|
* @param workerCount
|
||||||
* the number of I/O worker threads to start
|
* the maximum number of I/O worker threads
|
||||||
*/
|
*/
|
||||||
public NioClientSocketChannelFactory(
|
public NioClientSocketChannelFactory(
|
||||||
Executor bossExecutor, Executor workerExecutor,
|
Executor bossExecutor, Executor workerExecutor,
|
||||||
|
|
|
@ -100,11 +100,32 @@ public class NioServerSocketChannelFactory implements ServerSocketChannelFactory
|
||||||
final Executor bossExecutor;
|
final Executor bossExecutor;
|
||||||
private final ChannelSink sink;
|
private final ChannelSink sink;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Creates a new instance. Calling this constructor is same with calling
|
||||||
|
* {@link #NioServerSocketChannelFactory(Executor, Executor, int)} with
|
||||||
|
* the number of available processors in the machine. The number of
|
||||||
|
* available processors is calculated by {@link Runtime#availableProcessors()}.
|
||||||
|
*
|
||||||
|
* @param bossExecutor
|
||||||
|
* the {@link Executor} which will execute the boss threads
|
||||||
|
* @param workerExecutor
|
||||||
|
* the {@link Executor} which will execute the I/O worker threads
|
||||||
|
*/
|
||||||
public NioServerSocketChannelFactory(
|
public NioServerSocketChannelFactory(
|
||||||
Executor bossExecutor, Executor workerExecutor) {
|
Executor bossExecutor, Executor workerExecutor) {
|
||||||
this(bossExecutor, workerExecutor, Runtime.getRuntime().availableProcessors());
|
this(bossExecutor, workerExecutor, Runtime.getRuntime().availableProcessors());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Creates a new instance.
|
||||||
|
*
|
||||||
|
* @param bossExecutor
|
||||||
|
* the {@link Executor} which will execute the boss threads
|
||||||
|
* @param workerExecutor
|
||||||
|
* the {@link Executor} which will execute the I/O worker threads
|
||||||
|
* @param workerCount
|
||||||
|
* the maximum number of I/O worker threads
|
||||||
|
*/
|
||||||
public NioServerSocketChannelFactory(
|
public NioServerSocketChannelFactory(
|
||||||
Executor bossExecutor, Executor workerExecutor,
|
Executor bossExecutor, Executor workerExecutor,
|
||||||
int workerCount) {
|
int workerCount) {
|
||||||
|
|
|
@ -88,6 +88,12 @@ public class OioClientSocketChannelFactory implements ClientSocketChannelFactory
|
||||||
|
|
||||||
final OioClientSocketPipelineSink sink;
|
final OioClientSocketPipelineSink sink;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Creates a new instance.
|
||||||
|
*
|
||||||
|
* @param workerExecutor
|
||||||
|
* the {@link Executor} which will execute the I/O worker threads
|
||||||
|
*/
|
||||||
public OioClientSocketChannelFactory(Executor workerExecutor) {
|
public OioClientSocketChannelFactory(Executor workerExecutor) {
|
||||||
if (workerExecutor == null) {
|
if (workerExecutor == null) {
|
||||||
throw new NullPointerException("workerExecutor");
|
throw new NullPointerException("workerExecutor");
|
||||||
|
|
|
@ -101,6 +101,14 @@ public class OioServerSocketChannelFactory implements ServerSocketChannelFactory
|
||||||
final Executor bossExecutor;
|
final Executor bossExecutor;
|
||||||
private final ChannelSink sink;
|
private final ChannelSink sink;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Creates a new instance.
|
||||||
|
*
|
||||||
|
* @param bossExecutor
|
||||||
|
* the {@link Executor} which will execute the boss threads
|
||||||
|
* @param workerExecutor
|
||||||
|
* the {@link Executor} which will execute the I/O worker threads
|
||||||
|
*/
|
||||||
public OioServerSocketChannelFactory(
|
public OioServerSocketChannelFactory(
|
||||||
Executor bossExecutor, Executor workerExecutor) {
|
Executor bossExecutor, Executor workerExecutor) {
|
||||||
if (bossExecutor == null) {
|
if (bossExecutor == null) {
|
||||||
|
|
Loading…
Reference in New Issue
Block a user