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

Method Summary

Modifier and Type	Method	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 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(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