io.netty.util.concurrent

Class DefaultExecutorServiceFactory

java.lang.Object

io.netty.util.concurrent.DefaultExecutorServiceFactory

All Implemented Interfaces:

ExecutorServiceFactory

public final class DefaultExecutorServiceFactory
extends Object
implements ExecutorServiceFactory

An implementation of an ExecutorServiceFactory that creates a new ForkJoinPool on each call to newExecutorService(int).

This ExecutorServiceFactory powers Netty's nio and epoll eventloops by default. Netty moved from managing its own threads and pinning a thread to each eventloop to an Executor-based approach. That way advanced users of Netty can plug in their own threadpools and gain more control of scheduling the eventloops.

The main reason behind choosing a ForkJoinPool as the default Executor is that it uses thread-local task queues, providing a high level of thread affinity to Netty's eventloops.

The whole discussion can be found on GitHub https://github.com/netty/netty/issues/2250.

Constructor Summary

Constructors

Constructor and Description
DefaultExecutorServiceFactory(Class<?> clazzNamePrefix)
DefaultExecutorServiceFactory(String namePrefix)

Method Summary

Methods

Modifier and Type	Method and Description
ExecutorService	newExecutorService(int parallelism)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultExecutorServiceFactory

public DefaultExecutorServiceFactory(Class<?> clazzNamePrefix)

Parameters:

clazzNamePrefix - the name of the class will be used to prefix the name of each ForkJoinWorkerThread with.

DefaultExecutorServiceFactory

public DefaultExecutorServiceFactory(String namePrefix)

Parameters:

namePrefix - the string to prefix the name of each ForkJoinWorkerThread with.

Method Detail

newExecutorService

public ExecutorService newExecutorService(int parallelism)

Specified by:

newExecutorService in interface ExecutorServiceFactory