本文详解如何将串行计算逻辑改造为基于 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 <-chan int, results chan<- string, baseKey string, wg *sync.WaitGroup) {
defer wg.Done()
for i := range jobs {
key := baseKey + "_" + strconv.Itoa(i)
res := "Hello: " + key
fmt.Printf("Worker %d processed job %d → %s\n", id, i, res)
results <- res
}
}
func main() {
num := compute(4194304)
if num <= 0 {
fmt.Println("No jobs to process")
return
}
// 创建带缓冲的 channel，避免阻塞（缓冲大小 = 任务总数）
jobs := make(chan int, num)
results := make(chan string, num)
// 启动固定数量的工作协程（例如 4 个），复用 goroutine 资源
const workerCount = 4
var wg sync.WaitGroup
for w := 1; w <= workerCount; w++ {
wg.Add(1)
go worker(w, jobs, results, "503969280ff8679135937ad7d23b06c5", &wg)
}
// 发送所有任务索引到 jobs channel
for i := 0; i < num; i++ {
jobs <- i
}
close(jobs) // 关闭 jobs，通知 workers 不再有新任务
// 等待所有 worker 完成
go func() {
wg.Wait()
close(results) // 所有结果写入完毕后关闭 results
}()
// 收集并打印全部结果
for result := range results {
fmt.Println(result)
}
}✅ 关键改进说明：
-
显式并发控制：使用
workerCount限制 goroutine 数量，防止内存爆炸； -
同步保障：
sync.WaitGroup确保所有 worker 完全退出后再关闭resultschannel； -
channel 关闭规范：仅由 sender（main）关闭
jobs，由 receiver（goroutine）协作关闭results； -
错误防御：添加
num 边界检查，避免空 channel 操作； - 日志可追溯：每个 worker 输出 ID 和处理索引，便于调试并发行为。
⚠️ 注意事项：
- ❌ 避免在循环内无节制启动 goroutine（如
for i:=0; i<n i go f>），易触发 OOM； </n> - ❌ 不要向已关闭的 channel 发送数据，会导致 panic；
- ❌ 不要从已关闭且无数据的 channel 无限接收（应配合
range或ok判断）； - ✅ 优先使用带缓冲 channel（
make(chan T, N)）缓解 sender/receiver 速率不匹配； - ✅ 对 CPU 密集型任务，goroutine 数量建议 ≈ 逻辑 CPU 核心数（可用
runtime.NumCPU()获取）。
掌握 goroutine 的“何时启、如何通、怎样收”，才是写出健壮并发 Go 程序的核心。真正的并发优势，永远建立在可控、可测、可维护的通信模型之上。
