Expand description
Worker pool executor with backpressure Worker pool executor with backpressure
Provides a bounded worker pool for running ScrapingService tasks
with adaptive backpressure via tokio bounded channels.
§Example
use stygian_graph::domain::executor::WorkerPool;
let pool = WorkerPool::new(4, 32);
pool.shutdown().await;Structs§
- Worker
Pool - High-performance worker pool with bounded backpressure.