From 0f5c62ade5e8e67406971b160eb369feeaa6c28d Mon Sep 17 00:00:00 2001 From: Chris Eager Date: Thu, 26 Oct 2023 18:31:18 -0500 Subject: [PATCH] Set max threads = min threads on command executor services --- .../textsecuregcm/workers/CommandDependencies.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/workers/CommandDependencies.java b/service/src/main/java/org/whispersystems/textsecuregcm/workers/CommandDependencies.java index 079757b2f..b25d5ab17 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/workers/CommandDependencies.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/workers/CommandDependencies.java @@ -77,12 +77,11 @@ record CommandDependencies( ScheduledExecutorService recurringJobExecutor = environment.lifecycle() .scheduledExecutorService(name(name, "recurringJob-%d")).threads(2).build(); Scheduler messageDeliveryScheduler = Schedulers.fromExecutorService( - environment.lifecycle().executorService("messageDelivery").maxThreads(4) - .build()); + environment.lifecycle().executorService("messageDelivery").minThreads(4).maxThreads(4).build()); ExecutorService keyspaceNotificationDispatchExecutor = environment.lifecycle() - .executorService(name(name, "keyspaceNotification-%d")).maxThreads(4).build(); + .executorService(name(name, "keyspaceNotification-%d")).minThreads(4).maxThreads(4).build(); ExecutorService messageDeletionExecutor = environment.lifecycle() - .executorService(name(name, "messageDeletion-%d")).maxThreads(4).build(); + .executorService(name(name, "messageDeletion-%d")).minThreads(4).maxThreads(4).build(); ExecutorService secureValueRecoveryServiceExecutor = environment.lifecycle() .executorService(name(name, "secureValueRecoveryService-%d")).maxThreads(8).minThreads(8).build(); ExecutorService storageServiceExecutor = environment.lifecycle()