org.nuxeo.ecm.core.work

Class WorkManagerImpl.WorkThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.nuxeo.ecm.core.work.WorkManagerImpl.WorkThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService

Enclosing class:

WorkManagerImpl

protected class WorkManagerImpl.WorkThreadPoolExecutor
extends ThreadPoolExecutor

A ThreadPoolExecutor that keeps available the list of running tasks.

Completed tasks are passed to another queue.

The scheduled queue and completed list are passed as arguments and can have different implementations (in-memory, persisted, etc).

Since:

5.6

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Field Summary

Fields

Modifier and Type	Field and Description
protected com.codahale.metrics.Counter	completedCount
protected String	queueId
protected ConcurrentLinkedQueue<Work>	running List of running Work instances, in order to be able to interrupt them if requested.
protected com.codahale.metrics.Counter	runningCount
protected com.codahale.metrics.Counter	scheduledCount
protected com.codahale.metrics.Timer	workTimer

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	WorkThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, NuxeoBlockingQueue queue, ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method and Description
protected void	afterExecute(Runnable r, Throwable t)
protected void	beforeExecute(Thread t, Runnable r)
void	execute(Runnable r)
void	execute(Work work) Executes the given task sometime in the future.
int	getScheduledOrRunningSize()
void	removeScheduled(String workId)
void	shutdownAndSuspend() Initiates a shutdown of this executor and asks for work instances to suspend themselves.
protected void	submit(Work work) go through the queue instead of using super.execute which may skip the queue and hand off to a thread directly

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Field Detail

queueId

protected final String queueId

running

protected final ConcurrentLinkedQueue<Work> running

List of running Work instances, in order to be able to interrupt them if requested.

scheduledCount

protected final com.codahale.metrics.Counter scheduledCount

runningCount

protected final com.codahale.metrics.Counter runningCount

completedCount

protected final com.codahale.metrics.Counter completedCount

workTimer

protected final com.codahale.metrics.Timer workTimer

Constructor Detail

WorkThreadPoolExecutor

protected WorkThreadPoolExecutor(int corePoolSize,
                                 int maximumPoolSize,
                                 long keepAliveTime,
                                 TimeUnit unit,
                                 NuxeoBlockingQueue queue,
                                 ThreadFactory threadFactory)

Method Detail

getScheduledOrRunningSize

public int getScheduledOrRunningSize()

execute

public void execute(Runnable r)

Specified by:

execute in interface Executor

Overrides:

execute in class ThreadPoolExecutor

execute

public void execute(Work work)

Executes the given task sometime in the future.

Parameters:

work - the work to execute

See Also:

execute(Runnable)

submit

protected void submit(Work work)
               throws RuntimeException

go through the queue instead of using super.execute which may skip the queue and hand off to a thread directly

Parameters:

work -

Throws:

RuntimeException

beforeExecute

protected void beforeExecute(Thread t,
                             Runnable r)

Overrides:

beforeExecute in class ThreadPoolExecutor

afterExecute

protected void afterExecute(Runnable r,
                            Throwable t)

Overrides:

afterExecute in class ThreadPoolExecutor

shutdownAndSuspend

public void shutdownAndSuspend()
                        throws InterruptedException

Initiates a shutdown of this executor and asks for work instances to suspend themselves.

Throws:

InterruptedException

removeScheduled

public void removeScheduled(String workId)