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

前言

創(chuàng)新互聯(lián)是少有的網(wǎng)站建設(shè)、成都網(wǎng)站制作、營銷型企業(yè)網(wǎng)站、小程序設(shè)計、手機(jī)APP,開發(fā)、制作、設(shè)計、賣鏈接、推廣優(yōu)化一站式服務(wù)網(wǎng)絡(luò)公司,于2013年創(chuàng)立,堅持透明化,價格低,無套路經(jīng)營理念。讓網(wǎng)頁驚喜每一位訪客多年來深受用戶好評

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

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

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

go-task的使用很簡單，只需要初始化一個任務(wù)處理器，然后往處理器里面添加任務(wù)，然后處理器就會異步地去執(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}, // 任務(wù)列表
   -1), // -1代表任務(wù)不超時
  )
 }

 time.Sleep(time.Second * 50)
}

// 下單任務(wù)
func ordering(uuid string, param map[string]interface{}) (string, error) {
 fmt.Println("i am ordering")
 time.Sleep(time.Second * 1)
 return uuid, nil
}

// 做菜任務(wù)
func cooking(uuid string, param map[string]interface{}) (string, error) {
 fmt.Println("i am cooking")
 time.Sleep(time.Second * 1)
 return uuid, nil
}

// 配送任務(wù)
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

總結(jié)

以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，如果有疑問大家可以留言交流，謝謝大家對創(chuàng)新互聯(lián)的支持。

名稱欄目：基于golangchannel實現(xiàn)的輕量級異步任務(wù)分發(fā)器示例代碼
文章URL：http://bm7419.com/article42/pcoihc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供營銷型網(wǎng)站建設(shè)、靜態(tài)網(wǎng)站、手機(jī)網(wǎng)站建設(shè)、網(wǎng)站導(dǎo)航、網(wǎng)站排名、企業(yè)網(wǎng)站制作

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)

成都網(wǎng)站建設(shè)公司