worker-pool

背景 我在做一个 Go 1.22 的 MQ 消费者服务（Kafka → 业务处理 → 写 MySQL），单副本 8C16G，峰值 ~2k msg/s。架构是典型的 worker pool：dispatcher 从 Kafka 拉到消息后 "