前言
有時候我們為了更好的利用計算機資源，可以把一些耗時長的任務隊列化異步執行。舉個對應簡單的生活中例子就是大多數餐廳里面點菜都是先找地方做，看了菜單選好菜之后找服務員點菜，此時再等待菜做好送上來。這里餐廳廚房就是計算機的底層資源，菜就是待執行的任務，而服務員就是我們的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中for循環遍歷channel時需要注意的問題詳解
- golang實現基于channel的通用連接池詳解
- Golang優雅關閉channel的方法示例
- golang中單向channel的語法介紹
- golang判斷chan channel是否關閉的方法
- Golang中channel使用的一些小技巧
- Golang中channel的原理解讀(推薦)
