From 821fa66d1d34a571e31b27a073767c1f61a3313a Mon Sep 17 00:00:00 2001 From: Luke <909599715@qq.com> Date: Mon, 31 Jul 2023 09:45:13 +0800 Subject: [PATCH] Replace the buffer pool type from ArrayBlockingQueue to LinkedBlockingQueue type --- .../springboot/starter/monitor/ReportingEventExecutor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/starters/threadpool/server/src/main/java/cn/hippo4j/springboot/starter/monitor/ReportingEventExecutor.java b/starters/threadpool/server/src/main/java/cn/hippo4j/springboot/starter/monitor/ReportingEventExecutor.java index 0038c62d..1175d2e3 100644 --- a/starters/threadpool/server/src/main/java/cn/hippo4j/springboot/starter/monitor/ReportingEventExecutor.java +++ b/starters/threadpool/server/src/main/java/cn/hippo4j/springboot/starter/monitor/ReportingEventExecutor.java @@ -136,7 +136,7 @@ public class ReportingEventExecutor implements Runnable, CommandLineRunner, Disp properties.getCollectInterval(), TimeUnit.MILLISECONDS); Integer bufferSize = properties.getTaskBufferSize(); - messageCollectVessel = new ArrayBlockingQueue(bufferSize); + messageCollectVessel = new LinkedBlockingQueue(bufferSize); // Get all data collection components, currently only historical operation data collection. collectors = ApplicationContextHolder.getBeansOfType(Collector.class); // Start reporting monitoring data thread.