Go Pond 怎样为子池划分父池的并发额度

使用 Pond v2 的 parent.NewSubpool(n) 为某类任务设置局部并发上限。子池任务仍使用父池的执行资源，所以既受自身上限约束，也受父池总额度约束。它提供的是“共享总额度下的局部限额”，不能理解成给某类任务永久保留 n 个执行位置。

官方地址：https://github.com/alitto/pond

用 NewSubpool 设置局部上限

// 父池统一承担执行资源；子池按业务类别设置上限。
parent := pond.NewPool(12)
reports := parent.NewSubpool(3)
imports := parent.NewSubpool(5)

// 关闭应放在提交方，先让子池完成，再关闭父池。
reports.StopAndWait()
imports.StopAndWait()
parent.StopAndWait()

这段配置中，reports 最多允许三个局部执行位置，imports 最多五个；父池额度是十二。创建子池并不会把父池本身的配置改成四，也不代表空闲额度被提前扣走。NewSubpool 接收整数上限，不是百分比：3 就是三个，不是父池的三成。

接口定义与用法见 Pond v2 API。本文假定额度在运行期间保持固定，不讨论运行中缩容的过渡状态。

共享额度适合解决什么压力

设想一个服务同时处理报表和导入：二者都需要数据库连接，但报表允许的同时执行量更小。分别创建两个独立池，可以限制各自任务，却缺少同一个父级总量约束。子池适合在同一资源预算之内，再按业务类别增加限制。

结构图中的 parent、reports、imports 表示池对象；总额度12、报表额度3、导入额度5 表示配置。reports 和 imports 均隶属 parent，各自关联局部额度，parent 关联总额度。

这个选择依据是业务约束，不代表子池必然更快。数据库连接数、任务耗时和远程服务承受能力都可能改变合适的额度。

按业务类别提交并等待结果

下面完整示例使用 SubmitErr 提交带错误返回值的任务。任务句柄保存在切片中，先完成所有提交，再逐个等待，避免每提交一个就立即等待而把工作意外串行化。示例仅展示组织方式，没有执行或附带实测输出。

package main

import (
    "fmt"
    "log"

    "github.com/alitto/pond/v2"
)

func main() {
    parent := pond.NewPool(12)
    reports := parent.NewSubpool(3)
    imports := parent.NewSubpool(5)

    // defer 按后进先出执行：两个子池先完成，父池最后关闭。
    defer parent.StopAndWait()
    defer reports.StopAndWait()
    defer imports.StopAndWait()

    tasks := make([]pond.Task, 0, 12)
    for i := 0; i 

项目需在 go.mod 中声明 github.com/alitto/pond/v2 并固定所选版本。任务很短时不一定同时占满所有额度，因此不能根据日志交错程度推断限流失效。上限是允许的最大值，并非必须达到的活跃数量。

SubmitErr、任务句柄、任务函数、Wait、错误结果 和 StopAndWait 各有职责：提交产生可等待句柄，任务函数提供错误，Wait 通过句柄取得结果；StopAndWait 负责池的结束等待，不替代业务错误处理。

避免把上限误当成资源预留

假设父池还有直接提交的任务，它们与子池任务同样竞争父池的执行资源。reports 的上限是三，不代表任何时候都保证三个报表任务马上开始。对有硬性时延保障的业务，只设置子池上限不足以提供调度保障，仍需安排独立资源或明确的服务级调度。

另一个反例是父池任务内部同步等待子池任务。如果父池的所有执行位置都被这些等待者占用，而子池又需要父池执行资源，可能形成互相等待。应把跨池编排放在池外的提交方，或重新安排依赖，不能用增大队列来解决执行额度被等待者占满的问题。

官方 pool.go 中子池工作通过父池提交，可以据此理解共享约束。源码还限制创建时子池上限不得高于父池当时上限。实际使用优先传明确的正整数，避免把零当作“禁用子池”；零的特殊含义应以项目固定版本为准。

用队列和退出责任补齐设计

并发额度限制同时执行的工作，队列容量限制等待的工作。即使只允许三个报表任务并发，如果提交速度长期高于处理速度，仍可能积压大量任务。需要积压上限时，另行配置 WithQueueSize，再确定队满时的提交策略；这些选项不应与 NewSubpool 的额度数字混在一起。

停机时先停止外部生产者，确保不再继续向子池提交；由池外的管理方等待子池排空，最后结束父池。不要提前关闭父池再期待子池队列继续正常得到执行资源。示例用 defer 明确这个责任，真实服务还要为停机超时和未完成作业设计持久化安排。

子池额度相加一定要等于父池吗？

不需要把各子池数字理解成静态分区。每个子池是局部上限，父池是共享总上限。即使配置的局部上限总和小于父池，也不代表父池配置自动缩小；总和超过父池时，也不会使父池总体限制失效。不要由此推导出公平或保底调度承诺。

子池会按创建时的比例自动跟随父池调整吗？

NewSubpool 接收的数值是明确的并发数量，没有在接口中声明按百分比自动跟随。需要改变配置时，应按固定版本的 Resize 语义单独规划父池与子池，不能把“三个位置”记成“固定占父池四分之一”。

等待所有任务完成，就能忽略任务错误吗？

不能。完成表示任务结束，成功还需要查看错误结果。保留任务句柄并处理 Wait 的错误，再由外层决定是否重试或补偿；不要在池内部同步等待另一个需要同一父级额度的任务。