如何避免 Golang Goroutine 池中常见的错误

package main

import (
    "context"
    "errors"
    "sync"
)

// ErrPoolFull 表示协程池已满。
var ErrPoolFull = errors.New("goroutine pool is full")

type GoroutinePool struct {
    ctx    context.Context
    cancel context.CancelFunc

    queue chan func()
    wg    sync.WaitGroup
    size  int
}

func NewGoroutinePool(ctx context.Context, size int) *GoroutinePool {
    ctx, cancel := context.WithCancel(ctx)
    return &GoroutinePool{
        ctx:    ctx,
        cancel: cancel,
        queue:  make(chan func(), size),
        wg:     sync.WaitGroup{},
        size:   size,
    }
}

func (p *GoroutinePool) Execute(task func()) error {
    select {
    case p.queue <- task:
        p.wg.Add(1)
        return nil
    default:
        return ErrPoolFull
    }
}

func (p *GoroutinePool) Wait() {
    p.wg.Wait()
}

func (p *GoroutinePool) Stop() {
    p.cancel()
    p.Wait()
}

func main() {
    // 创建一个大小为 10 的 Goroutine 池。
    pool := NewGoroutinePool(context.Background(), 10)

    // 向池中添加任务。
    for i := 0; i < 100; i++ {
        task := func() {}
        if err := pool.Execute(task); err != nil {
            // 处理协程池已满的情况。
        }
    }

    // 等待所有任务完成。
    pool.Wait()
}

// 处理协程池已满的情况。
if err := pool.Execute(task); err != nil {
    // 处理错误。
}

// 等待所有任务完成。
pool.Wait()

// 正确关闭协程池。
pool.Stop()

func task() {
    defer func() {
        if r := recover(); r != nil {
            // 处理异常。
        }
    }()

    // 任务代码。
}

// 异步执行 HTTP 请求。
go func() {
    resp, err := http.Get("https://example.com")
    if err != nil {
        // 处理错误。
    }

    // 处理响应。
}()