Golang通过goroutine实现高并发，但需控制数量避免资源耗尽。任务队列+Worker池可有效管理并发：使用channel作为任务队列，启动固定worker从队列消费任务，实现生产者-消费者模型。示例代码展示3个worker处理8个任务，通过Submit提交任务、Stop关闭池。优化方向包括为Task添加回调函数以支持结果返回与错误处理，提升灵活性。对于复杂场景，推荐使用ants等成熟库，支持自动伸缩、超时控制、panic捕获，提升稳定性与性能。根据业务需求选择原生实现或第三方库，能有效提高资源利用率和服务可靠性。
在高并发场景下，Golang 通过 goroutine 能轻松实现并发处理，但如果无限制地创建 goroutine，会导致系统资源耗尽。为解决这个问题，使用 任务队列 + Worker 池 是一种常见且高效的方案。它能控制并发数量、复用执行单元、提高资源利用率。
任务队列与 Worker 池的基本原理
任务队列用于存放待处理的任务，Worker 池中的每个 worker 从队列中取出任务并执行。这种模式类似于生产者-消费者模型：
- 生产者：将任务发送到任务队列
- 任务队列：缓冲任务，通常用有缓冲的 channel 实现
- Worker 池：一组长期运行的 goroutine，从队列中消费任务
使用 channel 实现简单的 Worker Pool
下面是一个基于 channel 的简单实现示例：
立即学习“go语言免费学习笔记（深入）”；
package main
<p>import (
"fmt"
"time"
)</p><p>// Task 表示一个任务
type Task struct {
ID int
Data string
}</p><p>// Worker 池结构体
type WorkerPool struct {
workers int
taskQueue chan Task
quit chan struct{}
}</p><p>// NewWorkerPool 创建一个新的 Worker 池
func NewWorkerPool(workers, queueSize int) *WorkerPool {
return &WorkerPool{
workers: workers,
taskQueue: make(chan Task, queueSize),
quit: make(chan struct{}),
}
}</p><p>// Start 启动 Worker 池
func (wp <em>WorkerPool) Start() {
for i := 0; i < wp.workers; i++ {
go func(workerID int) {
for {
select {
case task := <-wp.taskQueue:
fmt.Printf("Worker %d 处理任务: %s\n", workerID, task.Data)
time.Sleep(500 </em> time.Millisecond) // 模拟处理时间
case <-wp.quit:
return
}
}
}(i + 1)
}
}</p><p>// Submit 提交任务
func (wp *WorkerPool) Submit(task Task) {
wp.taskQueue <- task
}</p><p>// Stop 停止 Worker 池
func (wp *WorkerPool) Stop() {
close(wp.quit)
close(wp.taskQueue)
}</p><p>func main() {
pool := NewWorkerPool(3, 10) // 3 个 worker，队列长度 10
pool.Start()</p><pre class='brush:php;toolbar:false;'>// 模拟提交任务
for i := 1; i <= 8; i++ {
pool.Submit(Task{ID: i, Data: fmt.Sprintf("数据-%d", i)})
}
time.Sleep(3 * time.Second)
pool.Stop()}
优化方向：支持任务回调与错误处理
实际项目中，任务执行后可能需要返回结果或处理错误。可以扩展 Task 结构，加入回调函数：
立即学习“go语言免费学习笔记（深入）”；
type Task struct {
ID int
Data string
Callback func(success bool, result string)
}
<p>// 在 worker 中执行任务后调用回调
case task := <-wp.taskQueue:
success := true
result := "处理完成：" + task.Data
if task.Callback != nil {
task.Callback(success, result)
}</p>这样可以让调用方知道任务执行状态，实现更灵活的控制逻辑。
使用第三方库（如 ants）提升效率
对于复杂场景，推荐使用成熟的第三方库，比如 ants，它提供了高性能、可复用的 goroutine 池。
安装：
go get github.com/panjf2000/ants/v2
使用示例：
package main
<p>import (
"fmt"
"sync"
"time"
"github.com/panjf2000/ants/v2"
)</p><p>func worker(taskID int) {
fmt.Printf("执行任务: %d\n", taskID)
time.Sleep(200 * time.Millisecond)
}</p><p>func main() {
// 创建协程池，最大 10 个 worker
pool, _ := ants.NewPool(10)
defer pool.Release()</p><pre class='brush:php;toolbar:false;'>var wg sync.WaitGroup
for i := 0; i < 20; i++ {
wg.Add(1)
_ = pool.Submit(func() {
defer wg.Done()
worker(i)
})
}
wg.Wait()
fmt.Println("所有任务完成")}
ants 支持自动伸缩、任务超时、panic 捕获等功能，适合生产环境。
基本上就这些。Golang 实现任务队列和 Worker 池并不复杂，关键是理解并发控制和 channel 的使用。根据业务需求选择原生实现或成熟库，能有效提升服务稳定性与性能。
