io.micronaut.scheduling.executor

Class ExecutorFactory

java.lang.Object

io.micronaut.scheduling.executor.ExecutorFactory

@Factory
public class ExecutorFactory
extends java.lang.Object

Constructs ExecutorService instances based on UserExecutorConfiguration instances.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
ExecutorFactory(BeanLocator beanLocator, java.util.concurrent.ThreadFactory threadFactory)
ExecutorFactory(java.util.concurrent.ThreadFactory threadFactory) Deprecated. Use ExecutorFactory(BeanLocator, ThreadFactory) instead

Method Summary

Modifier and Type	Method and Description
protected java.util.concurrent.ThreadFactory	eventLoopGroupThreadFactory(ExecutorConfiguration configuration) Constructs an executor thread factory.
java.util.concurrent.ExecutorService	executorService(ExecutorConfiguration executorConfiguration) Create the ExecutorService with the given configuration.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorFactory

@Deprecated
public ExecutorFactory(java.util.concurrent.ThreadFactory threadFactory)

Deprecated. Use ExecutorFactory(BeanLocator, ThreadFactory) instead

Parameters:

threadFactory - The factory to create new threads

ExecutorFactory

@Inject
public ExecutorFactory(BeanLocator beanLocator,
                               java.util.concurrent.ThreadFactory threadFactory)

Parameters:

beanLocator - The bean beanLocator

threadFactory - The factory to create new threads

Since:

2.0.1

Method Detail

eventLoopGroupThreadFactory

@EachBean(value=ExecutorConfiguration.class)
protected java.util.concurrent.ThreadFactory eventLoopGroupThreadFactory(ExecutorConfiguration configuration)

Constructs an executor thread factory.

Parameters:

configuration - The configuration

Returns:

The thread factory

executorService

@EachBean(value=ExecutorConfiguration.class)
 @Bean(preDestroy="shutdown")
public java.util.concurrent.ExecutorService executorService(ExecutorConfiguration executorConfiguration)

Create the ExecutorService with the given configuration.

Parameters:

executorConfiguration - The configuration to create a thread pool that creates new threads as needed

Returns:

A thread pool that creates new threads as needed