io.sarl.sre.services.executor

Class AbstractThreadExecutorPolicy

java.lang.Object

io.sarl.sre.services.executor.AbstractThreadExecutorPolicy

All Implemented Interfaces:

Thread.UncaughtExceptionHandler, RejectedExecutionHandler

@Singleton
public abstract class AbstractThreadExecutorPolicy
extends Object
implements RejectedExecutionHandler, Thread.UncaughtExceptionHandler

Abstract implementation of the thread executor policies for rejected tasks and uncaught exceptions.

The handler for rejected tasks runs the rejected task directly in the calling thread of the execute method, unless the executor has been shut down, in which case the task is discarded (see ThreadPoolExecutor.CallerRunsPolicy).

Version:

io.janusproject.plugin 0.12.0 20210527-171007

Author:

Stéphane Galland

See Also:

ThreadPoolExecutor.CallerRunsPolicy}

Maven Group Id:

io.janusproject.sre

Maven Artifact Id:

io.janusproject.plugin

Method Summary

Modifier and Type	Method and Description
void	rejectedExecution(runnable : 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

Methods inherited from interface java.lang.Thread.UncaughtExceptionHandler

uncaughtException

Method Detail

runRejectedTask

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

Description copied from class: AbstractThreadExecutorPolicy

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.

See Also:

ThreadPoolExecutor.CallerRunsPolicy}

rejectedExecution

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

Specified by:

rejectedExecution in interface RejectedExecutionHandler