基于golang channel实现的轻量级异步任务分发器示例代码
2019/7/10 22:06:29
本文主要是介绍基于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 channel实现的轻量级异步任务分发器示例代码的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-10-012024年每个初学者都应该知道的Django十大技巧
- 2024-09-30云原生周刊:Argo CD v2.13 发布候选版本丨2024.9.30
- 2024-09-29哪个更快:OpenAI Whisper、Google TTS 还是 Piper TTS??
- 2024-09-29MLOps 端到端系统在 Google 云平台(I):赋能预测解决方案
- 2024-09-26通过 gcloud CLI 认证从本地脚本写入 Google Sheets
- 2024-09-24GoLand 新建项目 Enable vendoring support automatically 的作用是什么?-icode9专业技术文章分享
- 2024-09-21MongoDB资料:新手入门与初级应用指南
- 2024-09-20MongoDB教程:初学者必备指南
- 2024-09-05MongoDB入门:快速掌握NoSQL数据库基础
- 2024-08-28go 项目中怎么打印调试-icode9专业技术文章分享