This is an automated email from the ASF dual-hosted git repository. vjasani pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/ambari.git
The following commit(s) were added to refs/heads/trunk by this push: new 9a3104b305 AMBARI-25912: use LinkedBlockingQueue in AgentsRegistrationQueue for performance improvement (#3672) 9a3104b305 is described below commit 9a3104b305f4e233736f6c1fd199f41600d04aa5 Author: jialiang <2510095...@qq.com> AuthorDate: Mon Aug 21 11:12:22 2023 +0800 AMBARI-25912: use LinkedBlockingQueue in AgentsRegistrationQueue for performance improvement (#3672) --- .../org/apache/ambari/server/agent/stomp/AgentsRegistrationQueue.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ambari-server/src/main/java/org/apache/ambari/server/agent/stomp/AgentsRegistrationQueue.java b/ambari-server/src/main/java/org/apache/ambari/server/agent/stomp/AgentsRegistrationQueue.java index 17518ad903..ffdaf1ecf0 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/agent/stomp/AgentsRegistrationQueue.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/agent/stomp/AgentsRegistrationQueue.java @@ -17,9 +17,9 @@ */ package org.apache.ambari.server.agent.stomp; -import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.Executors; +import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ThreadFactory; import java.util.concurrent.TimeUnit; @@ -46,7 +46,7 @@ public class AgentsRegistrationQueue { public AgentsRegistrationQueue(Injector injector) { Configuration configuration = injector.getInstance(Configuration.class); - registrationQueue = new ArrayBlockingQueue<>(configuration.getAgentsRegistrationQueueSize()); + registrationQueue = new LinkedBlockingQueue<>(configuration.getAgentsRegistrationQueueSize()); } public boolean offer(String sessionId) { --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@ambari.apache.org For additional commands, e-mail: commits-h...@ambari.apache.org