akka.dispatch
Class SaneRejectedExecutionHandler

java.lang.Object
  akka.dispatch.SaneRejectedExecutionHandler

All Implemented Interfaces:

java.util.concurrent.RejectedExecutionHandler

public class SaneRejectedExecutionHandler
extends java.lang.Object
implements java.util.concurrent.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

SaneRejectedExecutionHandler()

Method Summary

void	rejectedExecution(java.lang.Runnable runnable, java.util.concurrent.ThreadPoolExecutor threadPoolExecutor)

Methods inherited from class java.lang.Object

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

Constructor Detail

SaneRejectedExecutionHandler

public SaneRejectedExecutionHandler()

Method Detail

rejectedExecution

public void rejectedExecution(java.lang.Runnable runnable,
                              java.util.concurrent.ThreadPoolExecutor threadPoolExecutor)

Specified by:

rejectedExecution in interface java.util.concurrent.RejectedExecutionHandler