Replace the buffer pool type from ArrayBlockingQueue to LinkedBlockin… (#1411)

* Replace the buffer pool type from ArrayBlockingQueue to LinkedBlockingQueue type

* Import LinkedBlockingQueue package
pull/1412/merge
Luke Liang 1 year ago committed by GitHub
parent abe77a7a98
commit 6f3a6e0cc2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -45,6 +45,7 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Optional; import java.util.Optional;
import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.BlockingQueue; import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -136,7 +137,7 @@ public class ReportingEventExecutor implements Runnable, CommandLineRunner, Disp
properties.getCollectInterval(), properties.getCollectInterval(),
TimeUnit.MILLISECONDS); TimeUnit.MILLISECONDS);
Integer bufferSize = properties.getTaskBufferSize(); Integer bufferSize = properties.getTaskBufferSize();
messageCollectVessel = new ArrayBlockingQueue(bufferSize); messageCollectVessel = new LinkedBlockingQueue(bufferSize);
// Get all data collection components, currently only historical operation data collection. // Get all data collection components, currently only historical operation data collection.
collectors = ApplicationContextHolder.getBeansOfType(Collector.class); collectors = ApplicationContextHolder.getBeansOfType(Collector.class);
// Start reporting monitoring data thread. // Start reporting monitoring data thread.

Loading…
Cancel
Save