GO并发控制库Concurrency怎么使用
这篇文章主要介绍“GO并发控制库Concurrency怎么使用”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“GO并发控制库Concurrency怎么使用”文章能帮助大家解决问题。
铁东ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景,ssl证书未来市场广阔!成为创新互联建站的ssl证书销售渠道,可以享受市场价格4-6折优惠!如果有意向欢迎电话联系或者加微信:028-86922220(备注:SSL证书合作)期待与您的合作!
Concurrency
install
GOPROXY=https://goproxy.cn go get -v github.com/lxzan/concurrency@latest
Feature
并发协程数量限制
支持
contex.Contex
支持
panic recover
, 返回包含错误堆栈的error
递归实现的任务调度, 不依赖
time.Ticker
和channel
Usage
WorkerGroup 工作组, 添加一组任务, 等待执行完成, 可以很好的替代
WaitGroup
.
package mainimport (
"fmt"
"github.com/lxzan/concurrency"
"sync/atomic")func main() {
sum := int64(0)
w := concurrency.NewWorkerGroup()
for i := int64(1); i <= 10; i++ {
w.AddJob(concurrency.Job{
Args: i,
Do: func(args interface{}) error {
fmt.Printf("%v ", args)
atomic.AddInt64(&sum, args.(int64))
return nil
},
})
}
w.StartAndWait()
fmt.Printf("sum=%d\n", sum)}
4 5 6 7 8 9 10 1 3 2 sum=55
WorkerQueue 工作队列, 可以不断往里面添加任务, 一旦有CPU资源空闲就去执行。
package mainimport (
"fmt"
"github.com/lxzan/concurrency"
"time")func Add(args interface{}) error {
arr := args.([]int)
ans := 0
for _, item := range arr {
ans += item }
fmt.Printf("args=%v, ans=%d\n", args, ans)
return nil}func Mul(args interface{}) error {
arr := args.([]int)
ans := 1
for _, item := range arr {
ans *= item }
fmt.Printf("args=%v, ans=%d\n", args, ans)
return nil}func main() {
args1 := []int{1, 3}
args2 := []int{1, 3, 5}
w := concurrency.NewWorkerQueue()
w.AddJob(
concurrency.Job{Args: args1, Do: Add},
concurrency.Job{Args: args1, Do: Mul},
concurrency.Job{Args: args2, Do: Add},
concurrency.Job{Args: args2, Do: Mul},
)
w.StopAndWait(30*time.Second)}
args=[1 3], ans=4args=[1 3 5], ans=15args=[1 3], ans=3args=[1 3 5], ans=9
关于“GO并发控制库Concurrency怎么使用”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注创新互联行业资讯频道,小编每天都会为大家更新不同的知识点。
网站标题:GO并发控制库Concurrency怎么使用
URL地址:http://myzitong.com/article/jhjdog.html