Golang WaitGroup和协程池的高效结合

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

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

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

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

下面是一个示例代码：

package mainimport ("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和协程池的结合，可以实现高效的并发操作，提高程序的性能。