Package com.flowable.platform.service.configuration.service

Class ThreadPoolTaskExecutorSystemConfigurationConfigurer

java.lang.Object

com.flowable.platform.service.configuration.service.ThreadPoolTaskExecutorSystemConfigurationConfigurer

All Implemented Interfaces:

SystemConfigurationConfigurer

public class ThreadPoolTaskExecutorSystemConfigurationConfigurer
extends Object
implements SystemConfigurationConfigurer

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected final int	corePoolSize
protected final int	maxPoolSize
protected static final String	PROPERTY_CORE_POOL_SIZE
protected static final String	PROPERTY_MAX_POOL_SIZE
protected static final String	PROPERTY_QUEUE_CAPACITY
protected final int	queueCapacity
protected final ThreadPoolTaskExecutor	threadPoolTaskExecutor
protected final String	type

Constructor Summary

Constructors

Constructor	Description
ThreadPoolTaskExecutorSystemConfigurationConfigurer(String type, ThreadPoolTaskExecutor threadPoolTaskExecutor)

Method Summary

Modifier and Type	Method	Description
void	applyConfiguration(com.fasterxml.jackson.databind.node.ObjectNode configuration)	Apply the given configuration.
void	applyDefaultConfiguration()	If possible applies the default configuration.
protected void	applyPoolConfiguration(int corePoolSize, int maxPoolSize)
protected void	applyQueueCapacityConfiguration(int queueCapacity)
static SystemConfigurationConfigurer	fromTaskExecutor(String type, TaskExecutor taskExecutor)
protected static int	getQueueCapacity(ThreadPoolTaskExecutor taskExecutor)
String	getType()	The type of the system configuration that this configurer is meant for
protected boolean	isQueueCapacityDifferenceAboveThreshold(int newQueueCapacity)
void	validateConfiguration(com.fasterxml.jackson.databind.node.ObjectNode configuration)	Validate the configuration

Methods inherited from class java.lang.Object

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

Field Details

PROPERTY_CORE_POOL_SIZE

protected static final String PROPERTY_CORE_POOL_SIZE

See Also:

• Constant Field Values

PROPERTY_MAX_POOL_SIZE

protected static final String PROPERTY_MAX_POOL_SIZE

See Also:

• Constant Field Values

PROPERTY_QUEUE_CAPACITY

protected static final String PROPERTY_QUEUE_CAPACITY

See Also:

• Constant Field Values

type

protected final String type

threadPoolTaskExecutor

protected final ThreadPoolTaskExecutor threadPoolTaskExecutor

corePoolSize

protected final int corePoolSize

maxPoolSize

protected final int maxPoolSize

queueCapacity

protected final int queueCapacity

Constructor Details

ThreadPoolTaskExecutorSystemConfigurationConfigurer

public ThreadPoolTaskExecutorSystemConfigurationConfigurer(String type,
 ThreadPoolTaskExecutor threadPoolTaskExecutor)

Method Details

getType

public String getType()

Description copied from interface: SystemConfigurationConfigurer

The type of the system configuration that this configurer is meant for

Specified by:

getType in interface SystemConfigurationConfigurer

applyDefaultConfiguration

public void applyDefaultConfiguration()

Description copied from interface: SystemConfigurationConfigurer

If possible applies the default configuration.

Specified by:

applyDefaultConfiguration in interface SystemConfigurationConfigurer

applyConfiguration

public void applyConfiguration(com.fasterxml.jackson.databind.node.ObjectNode configuration)

Description copied from interface: SystemConfigurationConfigurer

Apply the given configuration.

Specified by:

applyConfiguration in interface SystemConfigurationConfigurer

Parameters:

configuration - the configuration to apply

applyPoolConfiguration

protected void applyPoolConfiguration(int corePoolSize,
 int maxPoolSize)

applyQueueCapacityConfiguration

protected void applyQueueCapacityConfiguration(int queueCapacity)

validateConfiguration

public void validateConfiguration(com.fasterxml.jackson.databind.node.ObjectNode configuration)

Description copied from interface: SystemConfigurationConfigurer

Validate the configuration

Specified by:

validateConfiguration in interface SystemConfigurationConfigurer

Parameters:

configuration - the configuration to validate

isQueueCapacityDifferenceAboveThreshold

protected boolean isQueueCapacityDifferenceAboveThreshold(int newQueueCapacity)

getQueueCapacity

protected static int getQueueCapacity(ThreadPoolTaskExecutor taskExecutor)

fromTaskExecutor

public static SystemConfigurationConfigurer fromTaskExecutor(String type,
 TaskExecutor taskExecutor)