fr.gouv.vitam.common.thread

Class VitamThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

fr.gouv.vitam.common.thread.VitamThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService, org.eclipse.jetty.util.thread.ThreadPool, org.glassfish.jersey.spi.ExecutorServiceProvider

@Named(value="threadpool")
 @ManagedAsyncExecutor
public class VitamThreadPoolExecutor
extends ThreadPoolExecutor
implements org.eclipse.jetty.util.thread.ThreadPool, org.glassfish.jersey.spi.ExecutorServiceProvider

Vitam ThreadPoolExecutor compatible with Jersey which copy the VitamSession from the main thread to the subthread

Nested Class Summary

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

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

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.ThreadPool

org.eclipse.jetty.util.thread.ThreadPool.SizedThreadPool

Constructor Summary

Constructors

Constructor and Description
VitamThreadPoolExecutor() Create a Cached Thread Pool
VitamThreadPoolExecutor(int minimumAvailableThreads) Create a Cached Thread Pool
VitamThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)

Method Summary

Modifier and Type	Method and Description
protected void	afterExecute(Runnable r, Throwable t) CLean up the session inside the thread.
protected void	beforeExecute(Thread t, Runnable r) Extract VitamSession from the given runnable, and sets it into the target (aka.
void	dispose(ExecutorService executorService)
void	execute(Runnable command) Pass the VitamSession through a VitamRunnable to the target Thread
static VitamThreadPoolExecutor	getDefaultExecutor() Default instance
ExecutorService	getExecutorService()
int	getIdleThreads()
int	getThreads()
boolean	isLowOnThreads()
void	join()

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

Constructor Detail

VitamThreadPoolExecutor

@Inject
 @Named(value="threadpool")
public VitamThreadPoolExecutor(int corePoolSize,
                                                                   int maximumPoolSize,
                                                                   long keepAliveTime,
                                                                   TimeUnit unit,
                                                                   BlockingQueue<Runnable> workQueue)

Parameters:

corePoolSize -

maximumPoolSize -

keepAliveTime -

unit -

workQueue -

VitamThreadPoolExecutor

@Inject
 @Named(value="threadpool")
public VitamThreadPoolExecutor()

Create a Cached Thread Pool

VitamThreadPoolExecutor

@Inject
 @Named(value="threadpool")
public VitamThreadPoolExecutor(int minimumAvailableThreads)

Create a Cached Thread Pool

Parameters:

minimumAvailableThreads - minimum Available Threads kept in the pool

Method Detail

getDefaultExecutor

public static VitamThreadPoolExecutor getDefaultExecutor()

Default instance

Returns:

VitamThreadPoolExecutor instance

execute

public void execute(Runnable command)

Pass the VitamSession through a VitamRunnable to the target Thread

Specified by:

execute in interface Executor

Overrides:

execute in class ThreadPoolExecutor

Parameters:

command -

beforeExecute

protected void beforeExecute(Thread t,
                             Runnable r)

Extract VitamSession from the given runnable, and sets it into the target (aka. current) Thread.

Carefully see ThreadPoolExecutor.beforeExecute(Thread, Runnable) documentation, especially about the thread executing this method.

Overrides:

beforeExecute in class ThreadPoolExecutor

Parameters:

r - Cf. ThreadPoolExecutor.beforeExecute(Thread, Runnable)

t - Cf. ThreadPoolExecutor.beforeExecute(Thread, Runnable)

afterExecute

protected void afterExecute(Runnable r,
                            Throwable t)

CLean up the session inside the thread.

Carefully see ThreadPoolExecutor.beforeExecute(Thread, Runnable) documentation, especially about the thread executing this method.

Overrides:

afterExecute in class ThreadPoolExecutor

Parameters:

r - Cf. ThreadPoolExecutor.beforeExecute(Thread, Runnable)

t - Cf. ThreadPoolExecutor.beforeExecute(Thread, Runnable)

join

public void join()
          throws InterruptedException

Specified by:

join in interface org.eclipse.jetty.util.thread.ThreadPool

Throws:

InterruptedException

getThreads

public int getThreads()

Specified by:

getThreads in interface org.eclipse.jetty.util.thread.ThreadPool

getIdleThreads

public int getIdleThreads()

Specified by:

getIdleThreads in interface org.eclipse.jetty.util.thread.ThreadPool

isLowOnThreads

public boolean isLowOnThreads()

Specified by:

isLowOnThreads in interface org.eclipse.jetty.util.thread.ThreadPool

getExecutorService

public ExecutorService getExecutorService()

Specified by:

getExecutorService in interface org.glassfish.jersey.spi.ExecutorServiceProvider

dispose

public void dispose(ExecutorService executorService)

Specified by:

dispose in interface org.glassfish.jersey.spi.ExecutorServiceProvider