用Go构建工作池的核心是启动固定数量goroutine作为工人，通过channel接收并执行任务，实现可控并发与资源复用；需定义Job函数类型和WorkerPool结构体，含jobs通道与workers数量，启动workers个for-range循环goroutine消费任务，提交时发送Job至jobs通道，关闭前可关闭channel实现优雅退出。
用 Go 构建工作池的核心是：启动固定数量的 goroutine 作为“工人”，通过 channel 接收任务，各自独立处理，避免无限制创建 goroutine 导致资源耗尽。关键不在“多”，而在“可控”和“复用”。
任务通常是一个函数或带参数的可执行单元。推荐用函数类型封装，便于传递：
type Job func()
工作池结构体至少包含任务队列（input channel）、工人数量、以及可选的完成通知机制：
type WorkerPool struct {
jobs chan Job
workers int
}注意 jobs channel 不需要缓冲（或按需设小缓冲），让发送方在池满时自然阻塞，实现背压控制。
立即学习“go语言免费学习笔记（深入）”；
每个工人持续从 jobs channel 中读取任务并执行。使用 for-range 可以在 channel 关闭后自动退出：
提交任务就是向 jobs channel 发送函数值：
pool := &WorkerPool{
jobs: make(chan Job, 100), // 缓冲可防短时突发
workers: 4,
}
for i := 0; i < pool.workers; i++ {
go func() {
for job := range pool.jobs {
job()
}
}()
}
<p>// 提交任务
pool.jobs <- func() { fmt.Println("do something") }如需等待所有任务完成，可用 sync.WaitGroup 配合关闭 channel：
若任务需返回结果或错误，可定义结构体封装：
type Result struct {
Value interface{}
Err error
}
type JobWithResult func() Result此时 jobs channel 类型变为 chan JobWithResult，再额外加一个 results chan Result 收集输出。主协程从 results channel 中读取，直到收到预期数量的结果。
基本上就这些。不复杂但容易忽略的是 channel 关闭时机和缓冲大小——它们直接决定吞吐与稳定性。
以上就是如何使用Golang构建工作池并分发任务_Golang WorkerPool任务分发说明的详细内容，更多请关注php中文网其它相关文章！
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移，垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是，许多工具可以让 Windows 保持平稳运行。
广告
收藏
收藏
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
872
