public void init(final TarsRegisterConfig tarsRegisterConfig) {
        if (StringUtils.isEmpty(tarsRegisterConfig.getThreadpool())) {
            CommunicatorConfig communicatorConfig = CommunicatorConfig.getDefault();
            Optional.ofNullable(tarsRegisterConfig.getCorethreads()).ifPresent(communicatorConfig::setCorePoolSize);
            Optional.ofNullable(tarsRegisterConfig.getThreads()).ifPresent(communicatorConfig::setMaxPoolSize);
            Optional.ofNullable(tarsRegisterConfig.getQueues()).ifPresent(communicatorConfig::setQueueSize);
            communicator = CommunicatorFactory.getInstance().getCommunicator(communicatorConfig);
        } else {
            initThreadPool(tarsRegisterConfig);
            Optional.ofNullable(threadPool).ifPresent(this::setCommunicatorThreadPool);
        }
    }
Init.

@param tarsRegisterConfig the tars register config
shenyu-plugin/shenyu-plugin-proxy/shenyu-plugin-rpc/shenyu-plugin-tars/src/main/java/org/apache/shenyu/plugin/tars/cache/ApplicationConfigCache.java