io.micronaut.scheduling.executor

Class DefaultExecutorSelector

java.lang.Object

io.micronaut.scheduling.executor.DefaultExecutorSelector

All Implemented Interfaces:

ExecutorSelector

@Singleton
public class DefaultExecutorSelector
extends Object
implements ExecutorSelector

Default implementation of the ExecutorSelector interface that regards methods that return reactive types as non-blocking.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DefaultExecutorSelector(BeanLocator beanLocator, BeanProvider<ExecutorService> ioExecutor) Default constructor.

Method Summary

Modifier and Type	Method and Description
Optional<ExecutorService>	select(MethodReference method, ThreadSelection threadSelection) Select an ExecutorService for the given MethodReference.
Optional<ExecutorService>	select(String name) Obtain executor for the given name.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultExecutorSelector

@Inject
protected DefaultExecutorSelector(BeanLocator beanLocator,
                                          @Named(value="io")
                                          BeanProvider<ExecutorService> ioExecutor)

Default constructor.

Parameters:

beanLocator - The bean locator

ioExecutor - The IO executor

Method Detail

select

public Optional<ExecutorService> select(MethodReference method,
                                        ThreadSelection threadSelection)

Description copied from interface: ExecutorSelector

Select an ExecutorService for the given MethodReference.

Specified by:

select in interface ExecutorSelector

Parameters:

method - The MethodReference

threadSelection - The thread selection mode

Returns:

An optional ExecutorService. If an ExecutorService cannot be established Optional.empty() is returned

select

public Optional<ExecutorService> select(String name)

Description copied from interface: ExecutorSelector

Obtain executor for the given name.

Specified by:

select in interface ExecutorSelector

Parameters:

name - The name of the executor

Returns:

An executor if it exists