golang框架在高并发场景中的性能优化

// 创建 10 个并发 goroutine
var wg sync.WaitGroup
for i := 0; i < 10; i++ {
    wg.Add(1)
    go func(i int) {
        // 并发任务
        wg.Done()
    }(i)
}
wg.Wait()

// 使用 Semaphore 限制并发
sem := make(chan struct{}, 10)

// 处理请求
for i := 0; i < 100; i++ {
    sem <- struct{}{}
    // ...处理请求的代码
    <-sem
}

// 创建 worker pool
type WorkerPool struct {
    tasks chan func()
    workers []worker
}

func NewWorkerPool(numWorkers int) *WorkerPool {
    wp := &WorkerPool{
        tasks:   make(chan func()),
        workers: make([]worker, numWorkers),
    }
    for i := range wp.workers {
        wp.workers[i] = newWorker(wp.tasks)
    }
    return wp
}

// 提交任务
func (wp *WorkerPool) Submit(task func()) {
    wp.tasks <- task
}

// 读写锁示例
type Counter struct {
    mu sync.RWMutex
    value int
}

// ...省略其他方法

// 缓存示例
type Cache struct {
    items map[string]interface{}
}

// ...省略其他方法