|
|
|
@ -115,11 +115,9 @@ public class ReportingEventExecutor implements Runnable, CommandLineRunner, Disp
|
|
|
|
|
ThreadFactoryBuilder.builder().daemon(true).prefix("client.scheduled.collect.data").build());
|
|
|
|
|
Collection<DynamicThreadPoolMonitor> dynamicThreadPoolMonitors =
|
|
|
|
|
DynamicThreadPoolServiceLoader.getSingletonServiceInstances(DynamicThreadPoolMonitor.class);
|
|
|
|
|
boolean customerDynamicThreadPoolMonitorFlag = CollectionUtil.isNotEmpty(dynamicThreadPoolMonitors) || (
|
|
|
|
|
collectType.contains(MonitorTypeEnum.PROMETHEUS.name().toLowerCase())
|
|
|
|
|
|| collectType.contains(MonitorTypeEnum.LOG.name().toLowerCase())
|
|
|
|
|
|| collectType.contains(MonitorTypeEnum.ES.name().toLowerCase())
|
|
|
|
|
);
|
|
|
|
|
boolean customerDynamicThreadPoolMonitorFlag = CollectionUtil.isNotEmpty(dynamicThreadPoolMonitors) || (collectType.contains(MonitorTypeEnum.PROMETHEUS.name().toLowerCase())
|
|
|
|
|
|| collectType.contains(MonitorTypeEnum.LOG.name().toLowerCase())
|
|
|
|
|
|| collectType.contains(MonitorTypeEnum.ES.name().toLowerCase()));
|
|
|
|
|
if (customerDynamicThreadPoolMonitorFlag) {
|
|
|
|
|
// Get all dynamic thread pool monitoring components.
|
|
|
|
|
Map<String, ThreadPoolMonitor> threadPoolMonitorMap = ApplicationContextHolder.getBeansOfType(ThreadPoolMonitor.class);
|
|
|
|
|