亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

這是Go中慣用的工作線程池嗎?

這是Go中慣用的工作線程池嗎?

Go
至尊寶的傳說 2019-08-19 16:57:09
這是Go中慣用的工作線程池嗎?我正在嘗試用goroutines編寫一個簡單的工作池。我寫的代碼是慣用的嗎?如果沒有,那么應該改變什么呢?我希望能夠將最大工作線程數設置為5并阻塞,直到工作人員可用,如果所有5個工作線都忙。我如何將此擴展到最多只有5名工作人員?我是否會產生靜態的5 goroutines,然后分別給它們work_channel?碼:package mainimport (     "fmt"     "math/rand"     "sync"     "time")func worker(id string, work string, o chan string, wg *sync.WaitGroup) {     defer wg.Done()     sleepMs := rand.Intn(1000)     fmt.Printf("worker '%s' received: '%s', sleep %dms\n", id, work, sleepMs)     time.Sleep(time.Duration(sleepMs) * time.Millisecond)     o <- work + fmt.Sprintf("-%dms", sleepMs)}func main() {     var work_channel = make(chan string)     var results_channel = make(chan string)     // create goroutine per item in work_channel     go func() {         var c = 0         var wg sync.WaitGroup         for work := range work_channel {             wg.Add(1)             go worker(fmt.Sprintf("%d", c), work, results_channel, &wg)             c++         }         wg.Wait()         fmt.Println("closing results channel")         close(results_channel)     }()     // add work to the work_channel     go func() {         for c := 'a'; c < 'z'; c++ {             work_channel <- fmt.Sprintf("%c", c)         }         close(work_channel)         fmt.Println("sent work to work_channel")     }()     for x := range results_channel {         fmt.Printf("result: %s\n", x)     }}
查看完整描述

2 回答

  • 2 回答
  • 0 關注
  • 1011 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號