org.infinispan.commons.executors

Class BlockingThreadPoolExecutorFactory

java.lang.Object

org.infinispan.commons.executors.BlockingThreadPoolExecutorFactory

All Implemented Interfaces:

ThreadPoolExecutorFactory

public class BlockingThreadPoolExecutorFactory
extends Object
implements ThreadPoolExecutorFactory

Author:

Galder Zamarreño

Constructor Summary

Constructors

Constructor and Description
BlockingThreadPoolExecutorFactory(int maxThreads, int coreThreads, int queueLength, long keepAlive)

Method Summary

Methods

Modifier and Type	Method and Description
int	coreThreads()
static BlockingThreadPoolExecutorFactory	create(int maxThreads, int queueSize)
ExecutorService	createExecutor(ThreadFactory threadFactory)
long	keepAlive()
int	maxThreads()
int	queueLength()
String	toString()
void	validate() Validate parameters for the thread pool executor factory

Constructor Detail

BlockingThreadPoolExecutorFactory

public BlockingThreadPoolExecutorFactory(int maxThreads,
                                 int coreThreads,
                                 int queueLength,
                                 long keepAlive)

Method Detail

maxThreads

public int maxThreads()

coreThreads

public int coreThreads()

queueLength

public int queueLength()

keepAlive

public long keepAlive()

createExecutor

public ExecutorService createExecutor(ThreadFactory threadFactory)

Specified by:

createExecutor in interface ThreadPoolExecutorFactory

validate

public void validate()

Description copied from interface: ThreadPoolExecutorFactory

Validate parameters for the thread pool executor factory

Specified by:

validate in interface ThreadPoolExecutorFactory

toString

public String toString()

Overrides:

toString in class Object

create

public static BlockingThreadPoolExecutorFactory create(int maxThreads,
                                       int queueSize)