feat(pool): Try different queue size (#4548)

iambriccardo · web-flow · commit c24440918b9d · 2025-03-05T10:01:40.000+01:00
diff --git a/relay-threading/src/pool.rs b/relay-threading/src/pool.rs
@@ -59,7 +59,7 @@ where
         S: ThreadSpawn,
     {
         let pool_name = builder.pool_name.unwrap_or(DEFAULT_POOL_NAME);
-        let (tx, rx) = flume::bounded(builder.num_threads * 2);
+        let (tx, rx) = flume::bounded(builder.num_threads * 10);
         let mut threads_metrics = Vec::with_capacity(builder.num_threads);
 
         for thread_id in 0..builder.num_threads {

Original file line number	Diff line number	Diff line change
`@@ -59,7 +59,7 @@ where`
`59`	`59`	`S: ThreadSpawn,`
`60`	`60`	`{`
`61`	`61`	`let pool_name = builder.pool_name.unwrap_or(DEFAULT_POOL_NAME);`
`62`		`- let (tx, rx) = flume::bounded(builder.num_threads * 2);`
	`62`	`+ let (tx, rx) = flume::bounded(builder.num_threads * 10);`
`63`	`63`	`let mut threads_metrics = Vec::with_capacity(builder.num_threads);`
`64`	`64`
`65`	`65`	`for thread_id in 0..builder.num_threads {`