MirrorMirror
/
Signal-Server
mirror of https://github.com/signalapp/Signal-Server.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Decrease message delivery executor thread count to 20

This commit is contained in:
Chris Eager 2023-04-06 10:27:53 -05:00 committed by Chris Eager
parent 23d5006f70
commit 33a6577b6e
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java
View File

@ -428,12 +428,11 @@ public class WhisperServerService extends Application<WhisperServerConfiguration
.executorService(name(getClass(), "storageService-%d")).maxThreads(1).minThreads(1).build(); .executorService(name(getClass(), "storageService-%d")).maxThreads(1).minThreads(1).build();
ExecutorService accountDeletionExecutor = environment.lifecycle().executorService(name(getClass(), "accountCleaner-%d")).maxThreads(16).minThreads(16).build(); ExecutorService accountDeletionExecutor = environment.lifecycle().executorService(name(getClass(), "accountCleaner-%d")).maxThreads(16).minThreads(16).build();
// using 80 threads to match Schedulers.boundedElastic() behavior
Scheduler messageDeliveryScheduler = Schedulers.fromExecutorService( Scheduler messageDeliveryScheduler = Schedulers.fromExecutorService(
ExecutorServiceMetrics.monitor(Metrics.globalRegistry, ExecutorServiceMetrics.monitor(Metrics.globalRegistry,
environment.lifecycle().executorService(name(getClass(), "messageDelivery-%d")) environment.lifecycle().executorService(name(getClass(), "messageDelivery-%d"))
.minThreads(80) .minThreads(20)
.maxThreads(80) .maxThreads(20)
.workQueue(messageDeliveryQueue) .workQueue(messageDeliveryQueue)
.build(), .build(),
MetricsUtil.name(getClass(), "messageDeliveryExecutor"), MetricsUtil.PREFIX), MetricsUtil.name(getClass(), "messageDeliveryExecutor"), MetricsUtil.PREFIX),