class TarsDtpAdapter extends AbstractDtpAdapter {

    private static final String TP_PREFIX = "tarsTp";

    private static final String COMMUNICATORS_FIELD = "CommunicatorMap";

    private static final String THREAD_POOL_FIELD = "threadPoolExecutor";

    private static final String COMMUNICATOR_ID_FIELD = "id";

    @Override
    public void refresh(DtpProperties dtpProperties) {
        refresh(dtpProperties.getTarsTp(), dtpProperties.getPlatforms());
    }

    @Override
    protected String getTpPrefix() {
        return TP_PREFIX;
    }

    @Override
    protected void initialize() {<FILL_FUNCTION_BODY>}
}

        super.initialize();

        CommunicatorFactory communicatorFactory = CommunicatorFactory.getInstance();
        val communicatorMap = (ConcurrentHashMap<Object, Communicator>) ReflectionUtil.getFieldValue(
                CommunicatorFactory.class, COMMUNICATORS_FIELD, communicatorFactory);
        if (MapUtils.isEmpty(communicatorMap)) {
            log.warn("Cannot find instances of type Communicator.");
            return;
        }
        communicatorMap.forEach((k, v) -> {
            val executor = (ThreadPoolExecutor) ReflectionUtil.getFieldValue(Communicator.class, THREAD_POOL_FIELD, v);
            if (Objects.isNull(executor)) {
                return;
            }
            val tpName = TP_PREFIX + "#" + ReflectionUtil.getFieldValue(Communicator.class, COMMUNICATOR_ID_FIELD, v);
            enhanceOriginExecutor(tpName, executor, THREAD_POOL_FIELD, v);
        });
    
<methods>public non-sealed void <init>() ,public Map<java.lang.String,org.dromara.dynamictp.core.support.ExecutorWrapper> getExecutorWrappers() ,public List<org.dromara.dynamictp.common.entity.ThreadPoolStats> getMultiPoolStats() ,public void refresh(List<org.dromara.dynamictp.common.entity.TpExecutorProps>, List<org.dromara.dynamictp.common.entity.NotifyPlatform>) ,public void refresh(org.dromara.dynamictp.core.support.ExecutorWrapper, List<org.dromara.dynamictp.common.entity.NotifyPlatform>, org.dromara.dynamictp.common.entity.TpExecutorProps) <variables>private static final Equator EQUATOR,protected final Map<java.lang.String,org.dromara.dynamictp.core.support.ExecutorWrapper> executors