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, Provider<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.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultExecutorSelector

protected DefaultExecutorSelector(BeanLocator beanLocator,
                                  @Named(value="io")
                                  Provider<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