Golang WaitGroup和协程池的高效结合

在Golang中，可以通过使用sync.WaitGroup和协程池来实现高效的并发操作。

首先，创建一个sync.WaitGroup对象并初始化其计数器为协程池的大小。计数器表示还有多少个协程在运行中。然后，将任务添加到一个任务队列中。

接下来，创建一个具有固定大小的协程池，可以使用Golang中的chan来实现。使用一个循环来启动协程，并且每个协程都会从任务队列中获取一个任务并执行。在协程执行完任务后，将计数器减1。

最后，在所有任务都被添加到任务队列中后，调用Wait方法等待所有协程执行完毕，然后继续执行后续的操作。

下面是一个示例代码：

package main
import (
"fmt"
"sync"
)
func main() {
// 创建一个WaitGroup对象
var wg sync.WaitGroup
// 初始化协程池的大小
poolSize := 10
// 初始化任务队列
taskQueue := make(chan int)
// 启动协程池
for i := 0; i < poolSize; i++ {
go func() {
// 从任务队列中获取任务并执行
for task := range taskQueue {
// 执行任务
fmt.Println("Processing task", task)
// 模拟任务执行时间
// time.Sleep(time.Second)
// 指示任务已完成
wg.Done()
}
}()
}
// 添加任务到任务队列
for i := 0; i < 100; i++ {
// 增加计数器
wg.Add(1)
// 将任务添加到任务队列中
taskQueue <- i
}
// 关闭任务队列
close(taskQueue)
// 等待所有协程执行完毕
wg.Wait()
fmt.Println("All tasks completed")
}

在上面的示例中，我们创建了一个大小为10的协程池，并添加了100个任务到任务队列中。每个任务会输出一条消息，并且通过time.Sleep模拟了任务的执行时间。最后，使用Wait方法等待所有协程执行完毕，并打印一条完成消息。

通过使用sync.WaitGroup和协程池的结合，可以实现高效的并发操作，提高程序的性能。