bigger worker queue

shuttle-hq · Nov 1, 2022 · 4d9d003 · 4d9d003
1 parent 9d0b1bb
commit 4d9d003
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/gateway/src/worker.rs b/gateway/src/worker.rs
@@ -4,6 +4,8 @@ use tracing::{debug, info};
 use crate::task::{BoxedTask, TaskResult};
 use crate::Error;
 
+const WORKER_QUEUE_SIZE: usize = 2048;
+
 pub struct Worker<W = BoxedTask> {
     send: Option<Sender<W>>,
     recv: Receiver<W>,
@@ -23,7 +25,7 @@ where
     W: Send,
 {
     pub fn new() -> Self {
-        let (send, recv) = channel(256);
+        let (send, recv) = channel(WORKER_QUEUE_SIZE);
         Self {
             send: Some(send),
             recv,