fr.gouv.vitam.common.thread

Class VitamThreadPoolExecutorProvider

java.lang.Object

org.glassfish.jersey.spi.AbstractThreadPoolProvider<ThreadPoolExecutor>

org.glassfish.jersey.spi.ThreadPoolExecutorProvider

fr.gouv.vitam.common.thread.VitamThreadPoolExecutorProvider

All Implemented Interfaces:

org.glassfish.jersey.spi.ExecutorServiceProvider

@ManagedAsyncExecutor
public class VitamThreadPoolExecutorProvider
extends org.glassfish.jersey.spi.ThreadPoolExecutorProvider

VItamThreadPoolExecutorProvider

Field Summary

Fields inherited from class org.glassfish.jersey.spi.AbstractThreadPoolProvider

DEFAULT_TERMINATION_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
VitamThreadPoolExecutorProvider(String name)

Method Summary

Modifier and Type	Method and Description
protected ThreadPoolExecutor	createExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)
void	dispose(ExecutorService executorService)
protected ThreadFactory	getBackingThreadFactory()
protected int	getCorePoolSize()
ExecutorService	getExecutorService()
protected long	getKeepAliveTime()
protected int	getMaximumPoolSize()
protected BlockingQueue<Runnable>	getWorkQueue()

Methods inherited from class org.glassfish.jersey.spi.ThreadPoolExecutorProvider

createExecutor, preDestroy

Methods inherited from class org.glassfish.jersey.spi.AbstractThreadPoolProvider

close, getExecutor, getRejectedExecutionHandler, getTerminationTimeout, isClosed, onClose

Methods inherited from class java.lang.Object

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

Constructor Detail

VitamThreadPoolExecutorProvider

public VitamThreadPoolExecutorProvider(String name)

Parameters:

name -

Method Detail

getExecutorService

public ExecutorService getExecutorService()

Specified by:

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

Overrides:

getExecutorService in class org.glassfish.jersey.spi.ThreadPoolExecutorProvider

createExecutor

protected ThreadPoolExecutor createExecutor(int corePoolSize,
                                            int maximumPoolSize,
                                            long keepAliveTime,
                                            BlockingQueue<Runnable> workQueue,
                                            ThreadFactory threadFactory,
                                            RejectedExecutionHandler handler)

Overrides:

createExecutor in class org.glassfish.jersey.spi.ThreadPoolExecutorProvider

getMaximumPoolSize

protected int getMaximumPoolSize()

Overrides:

getMaximumPoolSize in class org.glassfish.jersey.spi.ThreadPoolExecutorProvider

getKeepAliveTime

protected long getKeepAliveTime()

Overrides:

getKeepAliveTime in class org.glassfish.jersey.spi.ThreadPoolExecutorProvider

getWorkQueue

protected BlockingQueue<Runnable> getWorkQueue()

Overrides:

getWorkQueue in class org.glassfish.jersey.spi.ThreadPoolExecutorProvider

dispose

public void dispose(ExecutorService executorService)

Specified by:

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

Overrides:

dispose in class org.glassfish.jersey.spi.ThreadPoolExecutorProvider

getCorePoolSize

protected int getCorePoolSize()

Overrides:

getCorePoolSize in class org.glassfish.jersey.spi.AbstractThreadPoolProvider<ThreadPoolExecutor>

getBackingThreadFactory

protected ThreadFactory getBackingThreadFactory()

Overrides:

getBackingThreadFactory in class org.glassfish.jersey.spi.AbstractThreadPoolProvider<ThreadPoolExecutor>