基于golang channel实现的轻量级异步任务分发器示例代码
前言
有时候我们为了更好的利用计算机资源，可以把一些耗时长的任务队列化异步执行。举个对应简单的生活中例子就是大多数餐厅里面点菜都是先找地方做，看了菜单选好菜之后找服务员点菜，此时再等待菜做好送上来。这里餐厅厨房就是计算机的底层资源，菜就是待执行的任务，而服务员就是我们的go channel。
关于消息队列有很多好用的框架，如nsq，nats，kafka等等。但有时我们只需要轻量级的异步任务工具，而不需要太过于"复杂"的框架相对于我们的需求来说。于是借鉴一些项目框架，做了一个小小的封装。
项目地址： https://github.com/chenhg5/go... （本地下载）
go-task的使用很简单，只需要初始化一个任务处理器，然后往处理器里面添加任务，然后处理器就会异步地去执行了。
举餐厅的例子，代码如下：
package main
import (
"runtime"
"fmt"
"time"
"github.com/chenhg5/go-task"
)
func main() {
// init
task.InitTaskReceiver(runtime.NumCPU())
// 有十个人同时点菜
for i := 0; i < 10; i++ {
task.AddTask(task.NewTask(
map[string]interface{}{
"paramA" : "value",
}, // 参数
[]task.FacFunc{ordering, cooking, deliverying}, // 任务列表
-1), // -1代表任务不超时
)
}
time.Sleep(time.Second * 50)
}
// 下单任务
func ordering(uuid string, param map[string]interface{}) (string, error) {
fmt.Println("i am ordering")
time.Sleep(time.Second * 1)
return uuid, nil
}
// 做菜任务
func cooking(uuid string, param map[string]interface{}) (string, error) {
fmt.Println("i am cooking")
time.Sleep(time.Second * 1)
return uuid, nil
}
// 配送任务
func deliverying(uuid string, param map[string]interface{}) (string, error) {
fmt.Println("i am deliverying")
time.Sleep(time.Second * 1)
return uuid, nil
}
跑一遍，就会看到：
i am ordering
i am ordering
i am ordering
i am ordering
i am ordering
i am ordering
i am ordering
i am ordering
i am cooking
i am cooking
i am cooking
i am cooking
i am cooking
i am cooking
i am cooking
i am cooking
i am deliverying
i am deliverying
i am deliverying
i am deliverying
i am deliverying
i am deliverying
i am deliverying
i am deliverying
i am ordering
i am ordering
i am cooking
i am cooking
i am deliverying
i am deliverying
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。
相关文章
这篇文章主要为大家介绍了go Antlr重构脚本解释器实现示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-08-08
Go语言中,http.NewServeMux()和http.HandleFunc()是两种不同的路由注册方式,前者创建独立的ServeMux实例,适合模块化和分层路由,灵活性高,但启动服务器时需要显式指定,后者使用全局默认的http.DefaultServeMux,适合简单场景,感兴趣的朋友跟随小编一起看看吧2025-02-02
Gin框架中的binding验证器为我们提供了简便的数据绑定和验证功能,通过合理使用binding和validate标签,我们可以确保API接口的数据合法性和完整性,这篇文章主要介绍了Go Gin框架中的binding验证器使用指南,需要的朋友可以参考下2024-07-07
在微服务架构中,链路追踪技术可以帮助我们跟踪请求在各个服务之间的传播路径,本文就来介绍一下Go语言微服务中实现链路追踪,感兴趣的可以了解一下2024-12-12
这篇文章主要为大家详细介绍了Go语言程序查看和诊断工具，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-11-11
Go语言中的sync.Map是一个高效的并发安全映射结构,适用于高并发读多写少的场景,它通过读写分离、无锁读取路径、写入时的锁保护等机制,提高了读取性能并减少了锁竞争,sync.Map不需要手动管理锁,降低了编程复杂性,适合需要简单并发访问的场合2024-10-10
本文主要介绍了Golang接入钉钉通知的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2022-08-08
go routine可以使用channel来进行通信,使用通信的手段来共享内存,下面这篇文章主要给大家介绍了关于Go语言入门学习之Channel通道的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考下2022-07-07
这篇文章主要为大家介绍了Go语言基础if条件语句的用法及示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步早日升职加薪2021-11-11
这篇文章主要给大家介绍了关于idea搭建go环境实现go语言开发的相关资料,文中通过图文介绍以及代码介绍的非常详细,对大家学习或者使用go具有一定的参考借鉴价值,需要的朋友可以参考下2024-01-01
最新评论