golang 限流器,控制并发,线程池

xie1xiao1jun · · 1648 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

## [gowp](https://github.com/xxjwxc/gowp) ## golang worker pool ,线程池 , 工作池 - 并发限制goroutine池。 - 限制任务执行的并发性,而不是排队的任务数。 - 无论排队多少任务,都不会阻止提交任务。 - 通过队列支持 - 限流器 - golang 工作池公共库 ### 支持最大任务数, 放到工作池里面 并等待全部完成 ```go package main import ( "fmt" "time" "github.com/xxjwxc/gowp/workerpool" ) func main() { wp := workerpool.New(10) //设置最大线程数 for i := 0; i < 20; i++ { //开启20个请求 ii := i wp.Do(func() error { for j := 0; j < 10; j++ { //每次打印0-10的值 fmt.Println(fmt.Sprintf("%v->\t%v", ii, j)) time.Sleep(1 * time.Second) } //time.Sleep(1 * time.Second) return nil }) } wp.Wait() fmt.Println("down") } ``` ## 限流器(cache) ```go package main import ( "fmt" "sync" "time" "github.com/xxjwxc/gowp/limiter" ) func main() { limiter := limiter.NewLimiter(limiter.WithLimit(10), limiter.WithNamespace("test"), limiter.WithTsTimeout(true) /*, limiter.WithRedis(res)*/) var wg sync.WaitGroup for i := 0; i < 20; i++ { wg.Add(1) go func() { defer wg.Done() token, _ := limiter.Acquire(10) // 获取一个 fmt.Println(token) time.Sleep(1 * time.Second) limiter.Release(token) // 回退 }() } wg.Wait() fmt.Println("down") } ``` ## 限流器(redis) ```go package main import ( "fmt" "sync" "time" "github.com/xxjwxc/gowp/limiter" "github.com/xxjwxc/public/myredis" ) func main() { conf := myredis.InitRedis(myredis.WithAddr("127.0.0.1:6379"), myredis.WithPwd("123456"), myredis.WithGroupName("test")) res, err := myredis.NewRedis(conf) if err != nil { fmt.Println(err) return } limiter := limiter.NewLimiter(limiter.WithRedis(res), limiter.WithLimit(10), limiter.WithNamespace("test") /*, limiter.WithRedis(res)*/) var wg sync.WaitGroup for i := 0; i < 20; i++ { wg.Add(1) go func() { defer wg.Done() token, _ := limiter.Acquire(10) // 获取一个 fmt.Println(token) time.Sleep(1 * time.Second) limiter.Release(token) // 回退 }() } wg.Wait() fmt.Println("down") } ``` ---------- ## 代码地址 [gowp](https://github.com/xxjwxc/gowp)

有疑问加站长微信联系(非本文作者))

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1648 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传