io.sarl.sre.boot.internal.services

Class ExecutorServiceModule

java.lang.Object

com.google.inject.AbstractModule

io.sarl.sre.boot.internal.services.ExecutorServiceModule

All Implemented Interfaces:

com.google.inject.Module

public class ExecutorServiceModule
extends com.google.inject.AbstractModule

Module for the execution services.

Version:

io.janusproject.plugin 0.12.0 20210527-171007

Author:

Stéphane Galland

Maven Group Id:

io.janusproject.sre

Maven Artifact Id:

io.janusproject.plugin

Method Summary

Modifier and Type	Method and Description
protected void	configure()
ExecutorService	provideJvmExecutorService(configuration : javax.inject.Provider<SreConfig>, rejectedExecutionHandler : javax.inject.Provider<RejectedExecutionHandler>) Construct a JVM executor service.
ScheduledExecutorService	provideJvmScheduledExecutorService(configuration : javax.inject.Provider<SreConfig>, rejectedExecutionHandler : javax.inject.Provider<RejectedExecutionHandler>) Construct a JVM scheduled executor service.
QuietThreadExecutorPolicy	provideQuietThreadExecutorPolicy() Construct a QuietThreadExecutorPolicy.
RejectedExecutionHandler	provideRejectedExecutionHandler(loggerCreator : javax.inject.Provider<JulLoggerCreator>, configuration : javax.inject.Provider<SreConfig>, injector : com.google.inject.Injector) Construct a handler for tasks that cannot be executed by a ThreadPoolExecutor.
VerboseThreadExecutorPolicy	providesVerboseThreadExecutorPolicy(logService : javax.inject.Provider<LoggingService>) Construct a VerboseThreadExecutorPolicy.
Thread.UncaughtExceptionHandler	providetUncaughtExceptionHandler(loggerCreator : javax.inject.Provider<JulLoggerCreator>, configuration : javax.inject.Provider<SreConfig>, injector : com.google.inject.Injector) Construct a handler for exceptions that are not catched.

Methods inherited from class com.google.inject.AbstractModule

addError, addError, addError, bind, bind, bind, bindConstant, binder, bindListener, bindListener, bindScope, configure, convertToTypes, currentStage, getMembersInjector, getMembersInjector, getProvider, getProvider, install, requestInjection, requestStaticInjection, requireBinding, requireBinding

Methods inherited from class java.lang.Object

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

Method Detail

configure

protected def configure() : void 

Overrides:

configure in class com.google.inject.AbstractModule

providesVerboseThreadExecutorPolicy

@Provides
 @Singleton
 @Pure
public def providesVerboseThreadExecutorPolicy(logService : javax.inject.Provider<LoggingService>) : VerboseThreadExecutorPolicy 

Description copied from class: ExecutorServiceModule

Construct a VerboseThreadExecutorPolicy.

Parameters:

logService - the service for logging.

Returns:

the policy.

provideQuietThreadExecutorPolicy

@Provides
 @Singleton
 @Pure
public def provideQuietThreadExecutorPolicy() : QuietThreadExecutorPolicy 

Description copied from class: ExecutorServiceModule

Construct a QuietThreadExecutorPolicy.

Returns:

the policy.

provideRejectedExecutionHandler

@Provides
 @Singleton
public def provideRejectedExecutionHandler(loggerCreator : javax.inject.Provider<JulLoggerCreator>,
                                                                 configuration : javax.inject.Provider<SreConfig>,
                                                                 injector : com.google.inject.Injector) : RejectedExecutionHandler 

Description copied from class: ExecutorServiceModule

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.

providetUncaughtExceptionHandler

@Provides
 @Singleton
public def providetUncaughtExceptionHandler(loggerCreator : javax.inject.Provider<JulLoggerCreator>,
                                                                  configuration : javax.inject.Provider<SreConfig>,
                                                                  injector : com.google.inject.Injector) : Thread.UncaughtExceptionHandler 

Description copied from class: ExecutorServiceModule

Construct a handler for exceptions that are not catched.

Parameters:

loggingConfig - the bootique configuration for log4j.

configuration - the general configuration.

injector - the current injector.

Returns:

the handler.

provideJvmExecutorService

@Provides
 @Singleton
public def provideJvmExecutorService(configuration : javax.inject.Provider<SreConfig>,
                                                           rejectedExecutionHandler : javax.inject.Provider<RejectedExecutionHandler>) : ExecutorService 

Description copied from class: ExecutorServiceModule

Construct a JVM executor service.

Parameters:

configuration - the general configuration.

rejectedExecutionHandler - the handler for rejected executions.

Returns:

the service.

provideJvmScheduledExecutorService

@Provides
 @Singleton
public def provideJvmScheduledExecutorService(configuration : javax.inject.Provider<SreConfig>,
                                                                    rejectedExecutionHandler : javax.inject.Provider<RejectedExecutionHandler>) : ScheduledExecutorService 

Description copied from class: ExecutorServiceModule

Construct a JVM scheduled executor service.

Parameters:

configuration - the general configuration.

rejectedExecutionHandler - the handler for rejected executions.

Returns:

the service.