rafaelcaricio/relay
1
0
Fork 0
forked from mirrors/relay
Code Pull requests Activity

Increase concurrency

Browse source
This commit is contained in:
asonix 2022-11-19 22:38:58 -06:00
parent 4267f52a7e
commit 9ede941ff7
1 changed files with 3 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/jobs.rs
View file

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