From 9ede941ff7a1394f8755ce787d69e847d0236f92 Mon Sep 17 00:00:00 2001
From: asonix <asonix@asonix.dog>
Date: Sat, 19 Nov 2022 22:38:58 -0600
Subject: [PATCH] Increase concurrency

---
 src/jobs.rs | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/src/jobs.rs b/src/jobs.rs
index 5327ed0..b82d820 100644
--- a/src/jobs.rs
+++ b/src/jobs.rs
@@ -48,8 +48,6 @@ pub(crate) fn create_workers(
         .map(|p| p.get())
         .unwrap_or(1) as u64;
 
-    let parallelism = (parallelism / 2).max(1);
-
     let shared = WorkerConfig::new_managed(Storage::new(ActixTimer), move |queue_handle| {
         JobState::new(
             state.clone(),
@@ -70,9 +68,9 @@ pub(crate) fn create_workers(
     .register::<apub::Forward>()
     .register::<apub::Reject>()
     .register::<apub::Undo>()
-    .set_worker_count("maintenance", parallelism)
-    .set_worker_count("apub", parallelism)
-    .set_worker_count("deliver", parallelism * 3)
+    .set_worker_count("maintenance", parallelism * 2)
+    .set_worker_count("apub", parallelism * 2)
+    .set_worker_count("deliver", parallelism * 8)
     .start_with_threads(NonZeroUsize::try_from(parallelism as usize).expect("nonzero"));
 
     shared.every(Duration::from_secs(60 * 5), Listeners);