attempt reducing cpu load by handling queue items one by one

osuAkatsuki · May 2, 2024 · 0fa8fba · 0fa8fba
1 parent f342931
commit 0fa8fba
Showing 1 changed file with 10 additions and 13 deletions.
diff --git a/src/processor/mod.rs b/src/processor/mod.rs
@@ -454,19 +454,16 @@ async fn rmq_listen(context: Arc<Context>) -> anyhow::Result<()> {
                 deserialized_data.rework_id
             );
 
-            let context_clone = context.clone();
-            tokio::spawn(async move {
-                let result = handle_queue_request(
-                    deserialized_data,
-                    context_clone,
-                    delivery.delivery_tag.clone(),
-                )
-                .await;
-
-                if result.is_err() {
-                    log::error!(error = result.unwrap_err().to_string(); "Error processing queue request");
-                }
-            });
+            let result = handle_queue_request(
+                deserialized_data,
+                context.clone(),
+                delivery.delivery_tag.clone(),
+            )
+            .await;
+
+            if result.is_err() {
+                log::error!(error = result.unwrap_err().to_string(); "Error processing queue request");
+            }
         }
 
         tokio::time::sleep(Duration::from_millis(100)).await;