本文详解如何将串行计算逻辑改造为并发执行的 goroutine 模式，重点介绍基于 channel 和 worker pool 的标准实践，避免常见竞态与阻塞问题，并提供可直接运行的完整示例。
本文详解如何将串行计算逻辑改造为并发执行的 goroutine 模式，重点介绍基于 channel 和 worker pool 的标准实践，避免常见竞态与阻塞问题，并提供可直接运行的完整示例。
在 Go 中，并发不是简单地给函数加 go 前缀就万事大吉——它需要合理协调任务分发、结果收集与资源控制。原始代码中 for 循环串行调用 out()，当该函数耗时较长时，确实可通过并发显著提升吞吐。但直接启动大量 goroutine（如 go out(...)）而不加约束，极易导致内存暴涨、调度过载甚至程序崩溃。
推荐采用 Worker Pool（工作池）模式，这是 Go 官方示例（如 Go by Example: Worker Pools）倡导的稳健方案：固定数量的工作协程从共享任务通道中持续取任务，处理后将结果写入结果通道。这种方式既控制了并发度，又实现了任务解耦与结果有序收集。
以下是重构后的完整实现（已修正原答案中的一处关键逻辑缺陷）：
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
}
// out 现在是纯工作函数：接收单个 job ID，生成并返回结果字符串
func out(key string, jobID int) string {
// 模拟耗时操作（例如网络请求、文件读写等）
// time.Sleep(10 * time.Millisecond)
return "Hello: " + key + "_" + strconv.Itoa(jobID)
}
func main() {
const numJobs = compute(4194304)
const numWorkers = 8 // 根据 CPU 核心数或 I/O 特性调整，避免过度并发
jobs := make(chan int, numJobs) // 缓冲通道，避免发送阻塞
results := make(chan string, numJobs)
// 启动固定数量的 worker goroutines
var wg sync.WaitGroup
for w := 0; w < numWorkers; w++ {
wg.Add(1)
go func() {
defer wg.Done()
for jobID := range jobs {
// 构造 key —— 注意：必须在 goroutine 内部构造，避免闭包变量复用问题！
key := Md5Str("503969280ff8679135937ad7d23b06c5" + "_" + strconv.Itoa(jobID))
result := out(key, jobID)
results <- result
}
}()
}
// 发送所有任务 ID 到 jobs 通道
for j := 0; j < numJobs; j++ {
jobs <- j
}
close(jobs) // 关闭 jobs 通道，通知 workers 无新任务
// 启动 goroutine 等待所有 worker 完成（使用 WaitGroup）
go func() {
wg.Wait()
close(results) // 所有 worker 结束后关闭 results
}()
// 收集并打印所有结果
for result := range results {
fmt.Println(result)
}
}关键改进与注意事项：
- ✅ 闭包安全：
key的计算移至 worker goroutine 内部，彻底规避i变量被多个 goroutine 共享导致的值错乱（原答案中go out(...)在循环中捕获i是典型陷阱）； - ✅ 可控并发度：通过
numWorkers显式限制并发 goroutine 数量，防止系统资源耗尽； - ✅ 优雅终止：使用
sync.WaitGroup确保所有 worker 完成后再关闭results通道，使range results能正常退出； - ✅ 通道缓冲：
jobs和results均设为带缓冲通道，避免因消费者/生产者速度不匹配造成死锁； - ⚠️ 避免忙等待：切勿在
main中用for k := 0; k 等待——若某 worker panic 或卡死，程序将永久阻塞；<code>range+close组合才是健壮做法； - ? 扩展建议：若需返回结构化结果（如
{jobID, result, err}），可定义结果 struct 并让results通道传输该类型。
掌握这种基于 channel + worker pool 的 goroutine 编写范式，你就能写出高可靠、易维护、可伸缩的 Go 并发程序。
