Struct BoundedSpawner 

pub struct BoundedSpawner<P: Send + 'static> { /* private fields */ }

通用有界并发原语：有界 mpsc(cap=K) + N 个常驻 worker + 溢出策略。

Implementations

impl<P: Send + 'static> BoundedSpawner<P>

pub fn new<F, Fut>( concurrency: usize, queue_cap: usize, overflow: Overflow, reply_tx: UnboundedSender<Tick>, run: F, ) -> Self

where F: Fn(Option<Correlation>, P) -> Fut + Clone + Send + 'static, Fut: Future<Output = PortOutcome> + Send + 'static,

构造：concurrency=N 个 worker；queue_cap=K；run = 每条 job 的 I/O 执行体 （async 闭包，返回 PortOutcome，仅在 job.corr=Some 时回报）。

N 个 worker 共享单队列（竞争 recv）；Persist 用 N=1 保写序。

pub fn new_observed<F, Fut>( concurrency: usize, queue_cap: usize, overflow: Overflow, reply_tx: UnboundedSender<Tick>, sink: Arc<dyn AsyncMetricSink>, pool: &'static str, run: F, ) -> Self

where F: Fn(Option<Correlation>, P) -> Fut + Clone + Send + 'static, Fut: Future<Output = PortOutcome> + Send + 'static,

构造带指标的工作池，并在公开 seam 上保持与 new 相同的执行语义。

pub async fn submit(&self, job: Job<P>)

入队一条 job。

• Block：send().await，满则阻塞泵（背压传导回 tick_tx）。
• DropNewest：try_send，满则丢本条（最新） + warn（泵不阻塞）。

pub async fn shutdown(self)

graceful drain：drop tx → worker recv None 退出 → join 全部。

pub async fn shutdown_with_timeout(self, limit: Duration) -> bool

有上限 graceful drain（fix/lifecycle-net-decouple）：drop tx → join，全程封顶 limit。 限内全 join 完成 → true；超时 → abort 残留 worker（放弃在途 job）+ false。

为何需上限：必达 Http reqwest 单条可卡满网络 timeout（连不上 ~30s），无上限会让 helix_destroy graceful drain 等满。不丢保证由乐观态持久化(status=Sending) + 重连重发 对账承担，不由「drain 必等满网络」承担——abort 在途 Http 不丢数据（消息仍 status=Sending 留库，靠重连兜底）。完整语义见 engine.rs 五不变量⑤ + driver AGENTS.md。