基于golang channel實現(xiàn)的輕量級異步任務分發(fā)器示例代碼

更新時間：2018年07月02日 16:49:19 作者：honhon

這篇文章主要給大家介紹了關于基于golang channel實現(xiàn)的輕量級異步任務分發(fā)器的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

前言

有時候我們?yōu)榱烁玫睦糜嬎銠C資源，可以把一些耗時長的任務隊列化異步執(zhí)行。舉個對應簡單的生活中例子就是大多數(shù)餐廳里面點菜都是先找地方做，看了菜單選好菜之后找服務員點菜，此時再等待菜做好送上來。這里餐廳廚房就是計算機的底層資源，菜就是待執(zhí)行的任務，而服務員就是我們的go channel。

關于消息隊列有很多好用的框架，如nsq，nats，kafka等等。但有時我們只需要輕量級的異步任務工具，而不需要太過于"復雜"的框架相對于我們的需求來說。于是借鑒一些項目框架，做了一個小小的封裝。

項目地址： https://github.com/chenhg5/go... （本地下載）

go-task的使用很簡單，只需要初始化一個任務處理器，然后往處理器里面添加任務，然后處理器就會異步地去執(zhí)行了。

舉餐廳的例子，代碼如下：

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",
   }, // 參數(shù)
   []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