Package org.apache.pekko.dispatch

Class SaneRejectedExecutionHandler

java.lang.Object

org.apache.pekko.dispatch.SaneRejectedExecutionHandler

All Implemented Interfaces:

RejectedExecutionHandler

public class SaneRejectedExecutionHandler
extends Object
implements RejectedExecutionHandler

The RejectedExecutionHandler used by Akka, it improves on CallerRunsPolicy by throwing a RejectedExecutionException if the executor isShutdown. (CallerRunsPolicy silently discards the runnable in this case, which is arguably broken)

Constructor Summary

Constructors

Constructor	Description
SaneRejectedExecutionHandler()

Method Summary

Modifier and Type	Method	Description
void	rejectedExecution(Runnable runnable, ThreadPoolExecutor threadPoolExecutor)

Methods inherited from class java.lang.Object

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

Constructor Details

SaneRejectedExecutionHandler

public SaneRejectedExecutionHandler()

Method Details

rejectedExecution

public void rejectedExecution(Runnable runnable,
 ThreadPoolExecutor threadPoolExecutor)

Specified by:

rejectedExecution in interface RejectedExecutionHandler