io.sarl.sre.janus.boot.internal.services
Class ExecutorServiceModule
All Superinterfaces:
io.bootique.di.BQModule
class ExecutorServiceModule
extends java.lang.Object
implements io.bootique.di.BQModule
Module for the execution services.
Maven Group Identifier:
io.sarl.sre.janus
Maven Artifact Identifier:
janus.kernel
Action Summary
Modifier and type Action and description
void configure(Binder)
java.util.concurrent.ExecutorService provideJvmExecutorService(Provider<T>,Provider<T>)
Construct a JVM executor service.
java.util.concurrent.ScheduledExecutorService provideJvmScheduledExecutorService(Provider<T>,Provider<T>)
Construct a JVM scheduled executor service.
QuietThreadExecutorPolicy provideQuietThreadExecutorPolicy
Construct a QuietThreadExecutorPolicy.
java.util.concurrent.RejectedExecutionHandler provideRejectedExecutionHandler(Provider<T>,Provider<T>,Injector)
Construct a handler for tasks that cannot be executed by a ThreadPoolExecutor.
VerboseThreadExecutorPolicy providesVerboseThreadExecutorPolicy(Provider<T>)
Construct a VerboseThreadExecutorPolicy.
java.lang.Thread.UncaughtExceptionHandler providetUncaughtExceptionHandler(Provider<T>,Provider<T>,Injector)
Construct a handler for exceptions that are not catched.
Action Details
configure(Binder) 
def configure(Binder)
provideJvmExecutorService(Provider<T>,Provider<T>) 
def provideJvmExecutorService(Provider<T>,Provider<T>) : java.util.concurrent.ExecutorService
Construct a JVM executor service.
Parameters:
configuration - the general configuration.
rejectedExecutionHandler - the handler for rejected executions.
Returns:
the service.
provideJvmScheduledExecutorService(Provider<T>,Provider<T>) 
def provideJvmScheduledExecutorService(Provider<T>,Provider<T>) : java.util.concurrent.ScheduledExecutorService
Construct a JVM scheduled executor service.
Parameters:
configuration - the general configuration.
rejectedExecutionHandler - the handler for rejected executions.
Returns:
the service.
provideQuietThreadExecutorPolicy 
def provideQuietThreadExecutorPolicy : QuietThreadExecutorPolicy
Construct a QuietThreadExecutorPolicy.
Returns:
the policy.
provideRejectedExecutionHandler(Provider<T>,Provider<T>,Injector) 
def provideRejectedExecutionHandler(Provider<T>,Provider<T>,Injector) : java.util.concurrent.RejectedExecutionHandler
Construct a handler for tasks that cannot be executed by a ThreadPoolExecutor.
Parameters:
loggerCreator - the logger creator.
configuration - the general configuration.
injector - the current injector
Returns:
the handler.
providesVerboseThreadExecutorPolicy(Provider<T>) 
def providesVerboseThreadExecutorPolicy(Provider<T>) : VerboseThreadExecutorPolicy
Construct a VerboseThreadExecutorPolicy.
Parameters:
logService - the service for logging.
Returns:
the policy.
providetUncaughtExceptionHandler(Provider<T>,Provider<T>,Injector) 
def providetUncaughtExceptionHandler(Provider<T>,Provider<T>,Injector) : java.lang.Thread.UncaughtExceptionHandler
Construct a handler for exceptions that are not catched.
Parameters:
loggerCreator - the creator of logger..
configuration - the general configuration.
injector - the current injector.
Returns:
the handler.