com.dtp.adapter.common

类 AbstractDtpAdapter

java.lang.Object

com.dtp.adapter.common.AbstractDtpAdapter

所有已实现的接口:

DtpAdapter, MetricsAware, EventListener, org.springframework.context.ApplicationListener<org.springframework.boot.context.event.ApplicationReadyEvent>

public abstract class AbstractDtpAdapter
extends Object
implements DtpAdapter, org.springframework.context.ApplicationListener<org.springframework.boot.context.event.ApplicationReadyEvent>

AbstractDtpAdapter related

从以下版本开始:

1.0.6

作者:

yanhom

字段概要

字段

限定符和类型	字段和说明
protected Map<String,com.dtp.common.dto.ExecutorWrapper>	executors

构造器概要

构造器

构造器和说明
AbstractDtpAdapter()

方法概要

限定符和类型	方法和说明
Map<String,com.dtp.common.dto.ExecutorWrapper>	getExecutorWrappers() Get executor wrappers.
List<com.dtp.common.dto.ThreadPoolStats>	getMultiPoolStats() Get multi thread pool stats.
protected void	initialize()
void	initNotifyItems(String poolName, com.dtp.common.dto.ExecutorWrapper executorWrapper)
void	onApplicationEvent(org.springframework.boot.context.event.ApplicationReadyEvent event)
void	refresh(String name, com.dtp.common.dto.ExecutorWrapper executorWrapper, List<com.dtp.common.dto.NotifyPlatform> platforms, com.dtp.common.config.SimpleTpProperties properties)
void	refresh(String name, List<com.dtp.common.config.SimpleTpProperties> properties, List<com.dtp.common.dto.NotifyPlatform> platforms)
void	register(String poolName, ThreadPoolExecutor threadPoolExecutor)

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

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

从接口继承的方法 com.dtp.adapter.common.DtpAdapter

checkRefreshParams, getExecutorWrapper, refresh

从接口继承的方法 com.dtp.core.support.MetricsAware

getPoolStats

从接口继承的方法 org.springframework.context.ApplicationListener

forPayload

字段详细资料

executors

protected final Map<String,com.dtp.common.dto.ExecutorWrapper> executors

构造器详细资料

AbstractDtpAdapter

public AbstractDtpAdapter()

方法详细资料

onApplicationEvent

public void onApplicationEvent(org.springframework.boot.context.event.ApplicationReadyEvent event)

指定者:

onApplicationEvent 在接口中 org.springframework.context.ApplicationListener<org.springframework.boot.context.event.ApplicationReadyEvent>

initialize

protected void initialize()

register

public void register(String poolName,
                     ThreadPoolExecutor threadPoolExecutor)

getExecutorWrappers

public Map<String,com.dtp.common.dto.ExecutorWrapper> getExecutorWrappers()

从接口复制的说明: DtpAdapter

Get executor wrappers.

指定者:

getExecutorWrappers 在接口中 DtpAdapter

返回:

executors

getMultiPoolStats

public List<com.dtp.common.dto.ThreadPoolStats> getMultiPoolStats()

Get multi thread pool stats.

指定者:

getMultiPoolStats 在接口中 MetricsAware

返回:

thead pools stats

initNotifyItems

public void initNotifyItems(String poolName,
                            com.dtp.common.dto.ExecutorWrapper executorWrapper)

refresh

public void refresh(String name,
                    List<com.dtp.common.config.SimpleTpProperties> properties,
                    List<com.dtp.common.dto.NotifyPlatform> platforms)

refresh

public void refresh(String name,
                    com.dtp.common.dto.ExecutorWrapper executorWrapper,
                    List<com.dtp.common.dto.NotifyPlatform> platforms,
                    com.dtp.common.config.SimpleTpProperties properties)