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(ExecutorService ioExecutor) Construct a default implementation for the given executor service for asynchronous IO tasks.

Method Summary

Modifier and Type	Method and Description
Optional<ExecutorService>	select(MethodReference method) 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(@Named(value="io")
                                  ExecutorService ioExecutor)

Construct a default implementation for the given executor service for asynchronous IO tasks.

Parameters:

ioExecutor - A service that provide method to manager termination and produce future for tracking progress of one or more asynchronous IO tasks.

Method Detail

select

public Optional<ExecutorService> select(MethodReference method)

Description copied from interface: ExecutorSelector

Select an ExecutorService for the given MethodReference.

Specified by:

select in interface ExecutorSelector

Parameters:

method - The MethodReference

Returns:

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