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	Description
protected	DefaultExecutorSelector(BeanLocator beanLocator, BeanProvider<ExecutorService> ioExecutor, BeanProvider<ExecutorService> blockingExecutor)	Default constructor.

Method Summary

Modifier and Type	Method	Description
Optional<ExecutorService>	select(@Nullable 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 Object

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

Methods inherited from interface ExecutorSelector

selectExecutor

Constructor Details

DefaultExecutorSelector

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

Default constructor.

Parameters:

beanLocator - The bean locator

ioExecutor - The IO executor

blockingExecutor - The blocking executor

Method Details

select

public Optional<ExecutorService> select(@Nullable 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