【文件属性】:
文件名称:workerpool:并发限制goroutine池
文件大小:14KB
文件格式:ZIP
更新时间:2021-05-07 19:38:08
concurrency worker-pool Go
工人池
并发限制goroutine池。 限制任务执行的并发性,而不是排队的任务数。 无论排队多少个任务,都永远不会阻止提交任务。
此实现基于以下想法:
安装
要安装此软件包,您需要设置Go工作区。 安装库的最简单方法是运行:
$ go get github.com/gammazero/workerpool
例子
package main
import (
"fmt"
"github.com/gammazero/workerpool"
)
func main () {
wp := workerpool . New ( 2 )
requests := [] string { "alpha" , "beta" , "gamma" , "delta" , "epsilon" }
for _ , r := range requests {
r := r
wp . Subm
【文件预览】:
workerpool-master
----.gitignore(284B)
----go.mod(119B)
----go.test.sh(271B)
----doc.go(3KB)
----.travis.yml(167B)
----workerpool.go(8KB)
----LICENSE(1KB)
----go.sum(227B)
----README.md(2KB)
----pacer()
--------pacer.go(3KB)
--------pacer_test.go(1KB)
--------README.md(539B)
----workerpool_test.go(13KB)