From 50ac7f9dc2b089e12bf58d1dd9dbfab159a77a67 Mon Sep 17 00:00:00 2001
From: Ravi Khadiwala <ravi@signal.org>
Date: Mon, 24 Jul 2023 11:50:02 -0500
Subject: [PATCH] adjust messageDeletionAsyncExecutor core pool size

---
 .../whispersystems/textsecuregcm/WhisperServerService.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java b/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java
index d3c62277b..2c8c16109 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java
@@ -311,7 +311,10 @@ public class WhisperServerService extends Application<WhisperServerConfiguration
     Metrics.gaugeCollectionSize(name(getClass(), "messageDeletionQueueSize"), Collections.emptyList(),
         messageDeletionQueue);
     ExecutorService messageDeletionAsyncExecutor = environment.lifecycle()
-        .executorService(name(getClass(), "messageDeletionAsyncExecutor-%d")).maxThreads(16)
+        .executorService(name(getClass(), "messageDeletionAsyncExecutor-%d"))
+        .minThreads(2)
+        .maxThreads(2)
+        .allowCoreThreadTimeOut(true)
         .workQueue(messageDeletionQueue).build();
 
     Accounts accounts = new Accounts(