com.atlassian.confluence.event
Class MonitorableCallerRunsPolicy

java.lang.Object
  extended by java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy
      extended by 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
MonitorableCallerRunsPolicy()
           
 
Method Summary
 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


Copyright © 2003–2015 Atlassian. All rights reserved.