com.atlassian.confluence.event
Class ConfluencePoolBasedEventExecutorFactory

java.lang.Object
  com.atlassian.event.internal.AbstractEventExecutorFactory
      com.atlassian.event.internal.DirectEventExecutorFactory
          com.atlassian.confluence.event.ConfluencePoolBasedEventExecutorFactory

All Implemented Interfaces:

com.atlassian.event.spi.EventExecutorFactory

public class ConfluencePoolBasedEventExecutorFactory
extends com.atlassian.event.internal.DirectEventExecutorFactory

Uses a ThreadPoolExecutor.CallerRunsPolicy for running threads in case if queue is full

Since:

5.3

Constructor Summary

ConfluencePoolBasedEventExecutorFactory(com.atlassian.event.config.EventThreadPoolConfiguration configuration, com.atlassian.event.internal.EventThreadFactory eventThreadFactory, java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)

Method Summary

java.util.concurrent.ThreadPoolExecutor	getExecutor()
protected java.util.concurrent.BlockingQueue<java.lang.Runnable>	getQueue()
java.util.concurrent.RejectedExecutionHandler	getRejectedExecutionHandler()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConfluencePoolBasedEventExecutorFactory

public ConfluencePoolBasedEventExecutorFactory(com.atlassian.event.config.EventThreadPoolConfiguration configuration,
                                               com.atlassian.event.internal.EventThreadFactory eventThreadFactory,
                                               java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)

Method Detail

getQueue

protected java.util.concurrent.BlockingQueue<java.lang.Runnable> getQueue()

Overrides:

getQueue in class com.atlassian.event.internal.DirectEventExecutorFactory

getExecutor

public java.util.concurrent.ThreadPoolExecutor getExecutor()

Specified by:

getExecutor in interface com.atlassian.event.spi.EventExecutorFactory

Overrides:

getExecutor in class com.atlassian.event.internal.AbstractEventExecutorFactory

getRejectedExecutionHandler

public java.util.concurrent.RejectedExecutionHandler getRejectedExecutionHandler()