基于golang channel实现的轻量级异步任务分发器示例代码

本篇文章向大家介绍《基于golang channel实现的轻量级异步任务分发器示例代码》，主要包括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 

跑一遍，就会看到：

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实现的轻量级异步任务分发器示例代码》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！