基于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
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。
相关文章
这篇文章主要介绍了golang int 转float 强转和高精度转操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-12-12
ringbuffer因为它能复用缓冲空间，通常用于网络通信连接的读写，虽然市面上已经有了go写的诸多版本的ringbuffer组件，但还是自己造一个吧2023-06-06
这篇文章主要介绍了golang两种调用rpc的方法,结合实例形式分析了Go语言调用rpc的原理与实现方法,需要的朋友可以参考下2016-07-07
Go语言在sync包中提供了一套多才多艺的同步机制,以及用于管理对共享资源的并发访问的原子操作,了解这些工具并为您的并发需求选择合适的工具是编写高效可靠的并发Go程序的关键,这篇文章主要介绍了Go语言中的`sync`包同步原语,需要的朋友可以参考下2023-12-12
哈希表是常见的数据结构，有的语言会将哈希称作字典或者映射，在Go中，哈希就是常见的数据类型map，本文就来聊聊Golang中map的相关知识吧2023-03-03
这篇文章主要介绍了golan参数校验Validator,validator包可以通过反射结构体struct的tag进行参数校验,下面来看看文章的详细介绍吧,需要的朋友也可以参考一下2021-12-12
在 Golang 领域,并发发送 HTTP 请求是优化 Web 应用程序的一项重要技能,本文探讨了实现此目的的各种方法,文中的示例代码讲解详细,希望对大家有所帮助2024-01-01
在我们开发的过程中,每个项目都需要时间这一类的函数,此时对time这个包的研究深度就显得尤为重要,这篇文章主要给大家介绍了关于如何通过一篇文章带你搞懂Go语言标准库Time的相关资料,需要的朋友可以参考下2022-10-10
在Go语言中，切片作为一种引用类型数据，相对数组而言是一种动态长度的数据类型，使用的场景也是非常多，所以本文主要来和大家聊聊切片的底层原理，需要的可以参考一下2023-06-06
这篇文章主要为大家详细介绍了Go语言中new()函数的相关知识以及具体用法，文中的示例代码讲解详细，具有一定的学习价值，感兴趣的小伙伴可以了解一下2023-05-05
最新评论