org.apache.shenyu.web.configuration

类 ShenyuThreadPoolConfiguration

java.lang.Object

org.apache.shenyu.web.configuration.ShenyuThreadPoolConfiguration

@Configuration
public class ShenyuThreadPoolConfiguration
extends java.lang.Object

The type shenyu thread pool configuration.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	ShenyuThreadPoolConfiguration.ShenyuThreadPoolExecutorDestructor The type shenyu thread pool executor destructor.

构造器概要

构造器

构造器和说明
ShenyuThreadPoolConfiguration()

方法概要

限定符和类型	方法和说明
org.apache.shenyu.common.concurrent.TaskQueue<java.lang.Runnable>	memoryLimitedTaskQueue(org.apache.shenyu.common.config.ShenyuConfig shenyuConfig) MemoryLimitedTaskQueue.
org.apache.shenyu.common.concurrent.TaskQueue<java.lang.Runnable>	memorySafeTaskQueue(org.apache.shenyu.common.config.ShenyuConfig shenyuConfig) MemorySafeTaskQueue.
org.apache.shenyu.common.concurrent.ShenyuThreadPoolExecutor	shenyuThreadPoolExecutor(org.apache.shenyu.common.config.ShenyuConfig shenyuConfig, org.springframework.beans.factory.ObjectProvider<org.apache.shenyu.common.concurrent.TaskQueue<java.lang.Runnable>> provider) create shenyu shared thread pool executor.
ShenyuThreadPoolConfiguration.ShenyuThreadPoolExecutorDestructor	shenyuThreadPoolExecutorDestructor() destroy the shenyu shared thread pool executor.

从类继承的方法 java.lang.Object

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

构造器详细资料

ShenyuThreadPoolConfiguration

public ShenyuThreadPoolConfiguration()

方法详细资料

memoryLimitedTaskQueue

@Bean
 @ConditionalOnMissingBean(value=org.apache.shenyu.common.concurrent.TaskQueue.class)
 @Qualifier(value="taskQueue")
 @ConditionalOnProperty(value="shenyu.shared-pool.max-work-queue-memory")
public org.apache.shenyu.common.concurrent.TaskQueue<java.lang.Runnable> memoryLimitedTaskQueue(org.apache.shenyu.common.config.ShenyuConfig shenyuConfig)

MemoryLimitedTaskQueue.

参数:

shenyuConfig - the shenyu config

返回:

instance of MemoryLimitedTaskQueue

memorySafeTaskQueue

@Bean
 @ConditionalOnMissingBean(value=org.apache.shenyu.common.concurrent.TaskQueue.class)
 @Qualifier(value="taskQueue")
 @ConditionalOnProperty(value="shenyu.shared-pool.max-free-memory")
public org.apache.shenyu.common.concurrent.TaskQueue<java.lang.Runnable> memorySafeTaskQueue(org.apache.shenyu.common.config.ShenyuConfig shenyuConfig)

MemorySafeTaskQueue.

参数:

shenyuConfig - the shenyu config

返回:

instance of MemorySafeTaskQueue

shenyuThreadPoolExecutor

@Bean
 @ConditionalOnProperty(name="shenyu.shared-pool.enable",
                       havingValue="true",
                       matchIfMissing=true)
public org.apache.shenyu.common.concurrent.ShenyuThreadPoolExecutor shenyuThreadPoolExecutor(org.apache.shenyu.common.config.ShenyuConfig shenyuConfig,
                                                                                                                                                                                                                                                    @Qualifier(value="taskQueue")
                                                                                                                                                                                                                                                    org.springframework.beans.factory.ObjectProvider<org.apache.shenyu.common.concurrent.TaskQueue<java.lang.Runnable>> provider)

create shenyu shared thread pool executor.

参数:

shenyuConfig - the shenyu config

provider - the queue bean provider

返回:

the shenyu thread pool executor

shenyuThreadPoolExecutorDestructor

@Bean
 @ConditionalOnBean(value=org.apache.shenyu.common.concurrent.ShenyuThreadPoolExecutor.class)
public ShenyuThreadPoolConfiguration.ShenyuThreadPoolExecutorDestructor shenyuThreadPoolExecutorDestructor()

destroy the shenyu shared thread pool executor.

返回:

the shenyu thread pool executor destructor