Package org.nuxeo.runtime.migration

Class MigrationServiceImpl.MigrationThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.nuxeo.runtime.migration.MigrationServiceImpl.MigrationThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService

Enclosing class:

MigrationServiceImpl

protected static class MigrationServiceImpl.MigrationThreadPoolExecutor
extends ThreadPoolExecutor

Thread pool executor that records Runnables to be able to request shutdown on them.

Since:

9.3

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	Description
protected final List<MigrationServiceImpl.MigratorWithContext>	runnables

Constructor Summary

Constructors

Constructor	Description
MigrationThreadPoolExecutor()

Method Summary

Modifier and Type	Method	Description
protected void	afterExecute(Runnable runnable, Throwable t)
protected void	beforeExecute(Thread thread, Runnable runnable)
void	requestShutdown()

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, execute, 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 Details

runnables

protected final List<MigrationServiceImpl.MigratorWithContext> runnables

Constructor Details

MigrationThreadPoolExecutor

public MigrationThreadPoolExecutor()

Method Details

beforeExecute

protected void beforeExecute(Thread thread,
 Runnable runnable)

Overrides:

beforeExecute in class ThreadPoolExecutor

afterExecute

protected void afterExecute(Runnable runnable,
 Throwable t)

Overrides:

afterExecute in class ThreadPoolExecutor

requestShutdown

public void requestShutdown()