本文详解如何将串行计算逻辑改造为基于 goroutine 和 channel 的并发模型，重点介绍 worker pool 模式、goroutine 启动时机、channel 缓冲与关闭规范，避免常见死锁与资源泄漏问题。
本文详解如何将串行计算逻辑改造为基于 goroutine 和 channel 的并发模型，重点介绍 worker pool 模式、goroutine 启动时机、channel 缓冲与关闭规范，避免常见死锁与资源泄漏问题。
在 Go 中，并发不是简单地为每个任务启动一个 go 语句——它需要协同的通信机制（channel）、合理的资源调度和明确的生命周期管理。原始代码中 for 循环逐次调用 out() 是典型的串行执行；当 out() 变得耗时（如涉及 I/O、网络或复杂计算），引入并发可显著提升吞吐量。但直接为每次迭代启动 goroutine（如 go out(...)）而不加协调，极易导致 goroutine 泛滥、结果丢失或程序挂起。
推荐采用 Worker Pool（工作池）模式，其核心思想是：固定数量的工作协程持续从共享任务队列（jobs channel）中读取任务，处理后将结果写入结果通道（results channel）。这种方式既控制并发度，又保证任务有序分发与结果可收集。
以下是重构后的生产级示例（已修正原答案中关键逻辑缺陷）：
package main
import (
"crypto/md5"
"encoding/hex"
"fmt"
"io"
"math"
"strconv"
"sync"
)
func Md5Str(str string) string {
m := md5.New()
io.WriteString(m, str)
return hex.EncodeToString(m.Sum(nil))
}
func compute(size int) int {
num := int(math.Floor(float64(size+256*1024-1)) / 256 / 1024)
return num
}
// 工作协程函数：从 jobs 读取索引 i，生成 key，调用 out，发送结果到 results
func worker(id int, jobs <p>✅ <strong>关键改进说明：</strong> </p>
-
显式并发控制：使用
workerCount限制 goroutine 数量，防止内存爆炸； -
同步保障：
sync.WaitGroup确保所有 worker 完全退出后再关闭resultschannel； -
channel 关闭规范：仅由 sender（main）关闭
jobs，由 receiver（goroutine）协作关闭results； -
错误防御：添加
num 边界检查，避免空 channel 操作； - 日志可追溯：每个 worker 输出 ID 和处理索引，便于调试并发行为。
⚠️ 注意事项：
- ❌ 避免在循环内无节制启动 goroutine（如
for i:=0; i），易触发 OOM； - ❌ 不要向已关闭的 channel 发送数据，会导致 panic；
- ❌ 不要从已关闭且无数据的 channel 无限接收（应配合
range或ok判断）； - ✅ 优先使用带缓冲 channel（
make(chan T, N)）缓解 sender/receiver 速率不匹配； - ✅ 对 CPU 密集型任务，goroutine 数量建议 ≈ 逻辑 CPU 核心数（可用
runtime.NumCPU()获取）。
掌握 goroutine 的“何时启、如何通、怎样收”，才是写出健壮并发 Go 程序的核心。真正的并发优势，永远建立在可控、可测、可维护的通信模型之上。
