15 Star 56 Fork 14

bits-chen / go-goes

加入 Gitee
与超过 800 万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
贡献代码
同步代码
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README.md

Go Goes

50行代码实现非常简洁的Goroutines协程池 - Go

Install

go get -u github.com/yoojia/go-goes

Dep

[[constraint]]
  name = "github.com/yoojia/go-goes"
  version = "0.1.0"

Usage

三个步骤:

  1. 创建GoesPool;
  2. 启动协程池;
  3. 通过Add方法添加任务函数;
// 指定协程池创建100个工作协程
pool := goes.NewGoesPoolDefault(100)
// 启动
pool.Start()

// 停止协程池,阻塞等待所有任务函数执行完毕后返回。
defer pool.Shutdown()

wg := new(sync.WaitGroup)

TASKS := int(1000 * 100)
for i := 0; i < TASKS; i++ {
    wg.Add(1)
    // 通过 Add 方法,向协程池添加等待调度的任务函数
    pool.Add(func() {
        wg.Done()
    })
}

wg.Wait()

Note

需要注意的问题:

  1. 必须调用Start方法来启动协程池,否则Add的任务不会被执行;
  2. Shutdown必须在调用Start之后调用,否则将一直阻塞不会返回
  3. Add方法,如果协程池已满,将阻塞,直到协程池有空闲Worker协程;

Projects

本项目同时在以下两个代码托管平台更新维护:

License

This package is licensed under Apache License 2.0. See LICENSE for details.

简介

50行代码实现非常简洁的Goroutines协程池 - Go 展开 收起
Go
Apache-2.0
取消

发行版

暂无发行版

go-goes

贡献者

全部

近期动态

加载更多
不能加载更多了
Go
1
https://gitee.com/bitschen/go-goes.git
git@gitee.com:bitschen/go-goes.git
bitschen
go-goes
go-goes
master

搜索帮助