From 47fba2125684e455a220ecd43bf15d937c794f2b Mon Sep 17 00:00:00 2001 From: sqwishy Date: Wed, 21 Sep 2022 21:05:19 -0700 Subject: [PATCH] remove delay between spawning each worker (#614) --- backend/src/lib.rs | 7 ------- 1 file changed, 7 deletions(-) diff --git a/backend/src/lib.rs b/backend/src/lib.rs index f3b0c01f1a..217c7fc3bd 100644 --- a/backend/src/lib.rs +++ b/backend/src/lib.rs @@ -12,7 +12,6 @@ use axum::{handler::Handler, middleware::from_extractor, routing::get, Extension use db::DB; use futures::FutureExt; use git_version::git_version; -use rand::Rng; use slack_http_verifier::SlackVerifier; use std::{net::SocketAddr, sync::Arc}; use tower::ServiceBuilder; @@ -234,7 +233,6 @@ pub async fn run_workers( }); let mut handles = Vec::new(); - let mut rng = rand::thread_rng(); for i in 1..(num_workers + 1) { let db1 = db.clone(); @@ -259,11 +257,6 @@ pub async fn run_workers( ) .await })); - //avoid having all the workers start at the same time - tokio::time::sleep(std::time::Duration::from_millis( - rng.gen_range(0..sleep_queue * num_workers as u64), - )) - .await; } futures::future::try_join_all(handles).await?; Ok(())