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 and Description
protected int	corePoolSize
protected int	maxPoolSize
protected static String	PROPERTY_CORE_POOL_SIZE
protected static String	PROPERTY_MAX_POOL_SIZE
protected static String	PROPERTY_QUEUE_CAPACITY
protected int	queueCapacity
protected ThreadPoolTaskExecutor	threadPoolTaskExecutor
protected String	type

Constructor Summary

Constructors

Constructor and Description
ThreadPoolTaskExecutorSystemConfigurationConfigurer(String type, ThreadPoolTaskExecutor threadPoolTaskExecutor)

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

ThreadPoolTaskExecutorSystemConfigurationConfigurer

public ThreadPoolTaskExecutorSystemConfigurationConfigurer(String type,
                                                           ThreadPoolTaskExecutor threadPoolTaskExecutor)

Method Detail

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)