Skip to content

Commit

Permalink
Replace the buffer pool type from ArrayBlockingQueue to LinkedBlockin… (
Browse files Browse the repository at this point in the history
#1411)

* Replace the buffer pool type from ArrayBlockingQueue to LinkedBlockingQueue type

* Import LinkedBlockingQueue package
  • Loading branch information
LukeLiang authored Jul 31, 2023
1 parent abe77a7 commit 6f3a6e0
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@
import java.util.Map;
import java.util.Optional;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
Expand Down Expand Up @@ -136,7 +137,7 @@ public void run(String... args) {
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.
Expand Down

0 comments on commit 6f3a6e0

Please sign in to comment.