goroutine 池是一种预分配的 goroutine 集合，可通过减少创建和销毁 goroutine 的开销来提高程序性能。它的实现步骤包括创建通道、启动 goroutine、发送任务和获取结果。通过使用 goroutine 池，开发人员可以并行处理任务，享受同时执行大量任务的优势，而无需处理创建和销毁多个 goroutine 的开销。

Goroutine 池：Golang 函数并发编程的 efficace 实现

什么是 Goroutine 池？

Goroutine 池是一种并发编程技术，用于管理一组预分配的 Goroutine。它通过减少频繁创建和销毁 Goroutine 所需的开销来提高程序的性能。

如何实现 Goroutine 池？

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

Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等

下载

在 Go 中，Goroutine 池可以轻松实现。以下是实现 Goroutine 池的步骤：

1. 创建通道：
   创建两个无缓冲通道：work 用于将任务发送到池中，done 用于接收完成的任务。
2. 启动 Goroutine：
   启动多个 Goroutine，它们从 work 通道中读取任务并执行它们。当它们完成时，它们将结果发送到 done 通道。
3. 发送任务：
   要将任务发送到池中，请将任务发送到 work 通道。
4. 获取结果：
   要获取任务的结果，请从 done 通道接收结果。

实战案例

以下是在 Goroutine 池中使用 Goroutine 并行处理任务的示例：

package main

import (
    "fmt"
    "sync"
)

// 我们的任务类型
type Task struct {
    Input  int
    Result int
}

// Goroutine 池
var pool = &sync.Pool{
    New: func() interface{} {
        return &Task{}
    },
}

// 工作人员 goroutine
func worker(work <-chan *Task, done chan<- *Task) {
    for task := range work {
        task.Result = task.Input * 2
        done <- task
    }
}

func main() {
    // 创建通道
    work := make(chan *Task)
    done := make(chan *Task)

    // 启动工作人员 goroutine
    for i := 0; i < 10; i++ {
        go worker(work, done)
    }

    // 发送任务到池中
    for i := 0; i < 100; i++ {
        task := pool.Get().(*Task)
        task.Input = i
        work <- task
    }

    // 关闭通道以停止工作人员 goroutine
    close(work)

    // 获取结果
    for i := 0; i < 100; i++ {
        task := <-done
        fmt.Println(task.Result)
        pool.Put(task)
    }
}

结论：

Goroutine 池是一种简单且有效的并发编程技术，可以提高程序的性能。通过实现这种模式，开发人员可以获得同时执行大量任务的好处，而无需处理创建和销毁大量 Goroutine 的开销。