如何在Golang中实现goroutine池_Golang goroutine池使用实践汇总-Golang-PHP中文网

如何在Golang中实现goroutine池_Golang goroutine池使用实践汇总

P粉602998670

发布： 2025-11-09 19:45:02

原创

405人浏览过

使用goroutine池可控制并发数量，避免内存暴涨和调度开销。通过第三方库ants或手动实现基于channel的worker池，能有效管理任务执行，适用于大量短时任务或受限外部服务调用，提升系统稳定性与性能。

如何在golang中实现goroutine池_golang goroutine池使用实践汇总

在Go语言中，goroutine虽然轻量，但如果无限制地创建，仍可能导致内存暴涨或调度开销增大。使用goroutine池可以有效控制并发数量，复用执行单元，提升系统稳定性与性能。下面介绍几种在Golang中实现和使用goroutine池的常见方式。

为什么需要goroutine池

Go的goroutine创建成本低，但不代表可以无限创建。大量goroutine会带来以下问题：

占用过多内存（每个goroutine初始栈约2KB）
GC压力上升，影响整体性能
频繁调度导致CPU上下文切换开销增加
对外部资源（如数据库连接、API限流）造成过大压力

goroutine池通过预设最大并发数，从队列中消费任务，避免上述问题。

使用第三方库：ants

ants 是目前最流行的Go goroutine池库，功能完整，性能优秀。

立即学习“go语言免费学习笔记（深入）”；

安装：

go get github.com/panjf2000/ants/v2

登录后复制

基本使用示例：

package main
<p>import (
"fmt"
"sync"
"time"
"github.com/panjf2000/ants/v2"
)</p><p>func worker(task int) {
fmt.Printf("处理任务: %d, 协程ID: %d\n", task, ants.GetWorkerPoolSize())
time.Sleep(time.Second)
}</p><p>func main() {
// 创建一个容量为10的协程池
pool, _ := ants.NewPool(10)
defer pool.Release()</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">var wg sync.WaitGroup

for i := 0; i < 100; i++ {
    wg.Add(1)
    _ = pool.Submit(func() {
        defer wg.Done()
        worker(i)
    })
}

wg.Wait()

登录后复制

}

特点：

ViiTor实时翻译

AI实时多语言翻译专家！强大的语音识别、AR翻译功能。

116

查看详情

支持同步提交（Submit）
可配置最大协程数、过期时间、任务队列长度等
提供运行时状态监控

手动实现简易goroutine池

如果不想引入第三方依赖，可以基于channel和worker模型手写一个简单池。

package main
<p>import (
"fmt"
"sync"
"time"
)</p><p>type Task func()</p><p>type Pool struct {
workers int
tasks   chan Task
wg      sync.WaitGroup
}</p><p>func NewPool(workers, queueSize int) *Pool {
return &Pool{
workers: workers,
tasks:   make(chan Task, queueSize),
}
}</p><p>func (p *Pool) Start() {
for i := 0; i < p.workers; i++ {
p.wg.Add(1)
go func() {
defer p.wg.Done()
for task := range p.tasks {
if task != nil {
task()
}
}
}()
}
}</p><p>func (p *Pool) Submit(task Task) {
p.tasks <- task
}</p><p>func (p *Pool) Close() {
close(p.tasks)
p.wg.Wait()
}</p><p>// 使用示例
func main() {
pool := NewPool(5, 100)
pool.Start()</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">for i := 0; i < 30; i++ {
    taskID := i
    pool.Submit(func() {
        fmt.Printf("执行任务 %d, 时间: %v\n", taskID, time.Now().Format("15:04:05"))
        time.Sleep(time.Millisecond * 300)
    })
}

pool.Close()
fmt.Println("所有任务完成")

登录后复制

}

核心逻辑：