io.janusproject.kernel.services.jdk.executors

Class JdkRejectedExecutionHandler

java.lang.Object

io.janusproject.kernel.services.jdk.executors.JdkRejectedExecutionHandler

All Implemented Interfaces:

RejectedExecutionHandler

public class JdkRejectedExecutionHandler
extends Object
implements RejectedExecutionHandler

A handler for rejected tasks and uncaught exceptions that logs a warning on the platform logger when a task is rejected, and an error for each uncaught exception.

Version:

0.10.0 2019-10-26 19:44:29

Author:

Stéphane Galland

See Also:

ThreadPoolExecutor.CallerRunsPolicy

Maven Group Id:

io.janusproject

Maven Artifact Id:

io.janusproject.plugin

Constructor Summary

Constructors

Constructor and Description
JdkRejectedExecutionHandler(logger : LogService) Constructor.

Method Summary

Modifier and Type	Method and Description
void	rejectedExecution(task : Runnable, executor : ThreadPoolExecutor)
protected static boolean	runRejectedTask(runnable : Runnable, executor : ThreadPoolExecutor) Run the given task within the current thread if the executor is not shut down.

Methods inherited from class java.lang.Object

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

Constructor Detail

JdkRejectedExecutionHandler

@Inject
public new(logger : LogService)

Constructor.

Parameters:

logger - the logging service that must be used for output the errors.

Method Detail

rejectedExecution

public def rejectedExecution(task : Runnable,
                             executor : ThreadPoolExecutor) : void 

Specified by:

rejectedExecution in interface RejectedExecutionHandler

runRejectedTask

protected static def runRejectedTask(runnable : Runnable,
                                     executor : ThreadPoolExecutor) : boolean 

Description copied from class: JdkRejectedExecutionHandler

Run the given task within the current thread if the executor is not shut down. The task is not run by the given executor. The executor is used for checking if the executor service is shut down.

Parameters:

runnable - the runnable task to be executed

executor - the executor attempting to give the shut down status

Returns:

true if the task is run. false if the task was not run.

Since:

0.7

See Also:

ThreadPoolExecutor.CallerRunsPolicy