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:
java.util.concurrent.RejectedExecutionHandler

public class MonitorableCallerRunsPolicy
extends java.util.concurrent.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(java.lang.Runnable r, java.util.concurrent.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(java.lang.Runnable r,
                              java.util.concurrent.ThreadPoolExecutor e)
Specified by:
rejectedExecution in interface java.util.concurrent.RejectedExecutionHandler
Overrides:
rejectedExecution in class java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy


Copyright © 2003-2014 Atlassian. All Rights Reserved.