org.nuxeo.ecm.core.event.impl
Class AsyncEventExecutor

java.lang.Object
  org.nuxeo.ecm.core.event.impl.AsyncEventExecutor

public class AsyncEventExecutor
extends Object

ThreadPoolExecutor of listeners for event bundles.

Nested Class Summary

static class

AsyncEventExecutor.NamedThreadFactory Creates non-daemon threads at normal priority.

Field Summary

static int

QUEUE_SIZE

Constructor Summary

AsyncEventExecutor(int poolSize, int maxPoolSize, int keepAliveTime, int queueSize)

Method Summary

static AsyncEventExecutor	create()
int	getActiveCount()
int	getMaxPoolSize()
int	getUnfinishedCount()
void	run(List<EventListenerDescriptor> listeners, EventBundle event)
void	setMaxPoolSize(int maxSize)
void	shutdown()
void	shutdown(long timeout)

Methods inherited from class java.lang.Object

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

Field Detail

QUEUE_SIZE

public static final int QUEUE_SIZE

See Also:

Constant Field Values

Constructor Detail

AsyncEventExecutor

public AsyncEventExecutor(int poolSize,
                          int maxPoolSize,
                          int keepAliveTime,
                          int queueSize)

Method Detail

create

public static AsyncEventExecutor create()

shutdown

public void shutdown()

shutdown

public void shutdown(long timeout)

run

public void run(List<EventListenerDescriptor> listeners,
                EventBundle event)

getUnfinishedCount

public int getUnfinishedCount()

getActiveCount

public int getActiveCount()

getMaxPoolSize

public int getMaxPoolSize()

setMaxPoolSize

public void setMaxPoolSize(int maxSize)