com.atlassian.confluence.event

Class MonitorableCallerRunsPolicy

java.lang.Object

java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy

com.atlassian.confluence.event.MonitorableCallerRunsPolicy

All Implemented Interfaces:

RejectedExecutionHandler

public class MonitorableCallerRunsPolicy
extends ThreadPoolExecutor.CallerRunsPolicy

ThreadPoolExecutor.CallerRunsPolicy implementation which publishes QueueOverflowEvent if there are no more threads or queue slots available to process all events

Since:

5.5

Constructor Summary

Constructors

Constructor and Description
MonitorableCallerRunsPolicy()

Method Summary

Modifier and Type	Method and Description
void	rejectedExecution(Runnable r, ThreadPoolExecutor e)

Methods inherited from class java.lang.Object

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

Constructor Detail

MonitorableCallerRunsPolicy

public MonitorableCallerRunsPolicy()

Method Detail

rejectedExecution

public void rejectedExecution(Runnable r,
                              ThreadPoolExecutor e)

Specified by:

rejectedExecution in interface RejectedExecutionHandler

Overrides:

rejectedExecution in class ThreadPoolExecutor.CallerRunsPolicy