goland协程池
时间: 2023-09-12 17:07:44 浏览: 140
好的,关于golang协程池,我可以给您一些解释和建议。
首先,协程池可以提高程序的效率,减少创建和销毁协程的开销。在golang中,可以使用sync包中的WaitGroup和Pool来实现协程池的功能。
WaitGroup可以用来等待一组协程的执行完成,而Pool可以用来管理协程的数量和复用协程。
下面是一个简单的示例代码:
```
package main
import (
"fmt"
"sync"
)
func worker(id int, jobs <-chan int, results chan<- int) {
for j := range jobs {
fmt.Println("worker", id, "started job", j)
fib := Fibonacci(j)
fmt.Println("worker", id, "finished job", j)
results <- fib
}
}
func Fibonacci(n int) int {
if n <= 1 {
return n
}
return Fibonacci(n-1) + Fibonacci(n-2)
}
func main() {
const numJobs = 10
jobs := make(chan int, numJobs)
results := make(chan int, numJobs)
// 创建协程池并启动10个协程
var wg sync.WaitGroup
for w := 1; w <= 10; w++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
worker(id, jobs, results)
}(w)
}
// 发送10个任务到协程池
for j := 1; j <= numJobs; j++ {
jobs <- j
}
close(jobs)
// 等待所有任务完成并关闭结果通道
wg.Wait()
close(results)
// 输出结果
for r := range results {
fmt.Println("result:", r)
}
}
```
在这个示例中,我们创建了一个有10个协程的协程池,并将10个任务发送到任务通道。每个协程会从通道中取出任务,执行任务,然后将结果发送到结果通道。最后,我们等待所有任务完成,关闭结果通道,并输出结果。
希望这个示例代码可以对您有所帮助。如果您有任何其他问题,请随时问我。
阅读全文