欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

golang 40行代碼實(shí)現(xiàn)通用協(xié)程池

 更新時(shí)間:2018年08月08日 14:02:49   作者:xialeistudio  
golang協(xié)程機(jī)制很方便的解決了并發(fā)編程的問題,但是協(xié)程并不是沒有開銷的,所以也需要適當(dāng)限制一下數(shù)量。這篇文章主要介紹了golang 40行代碼實(shí)現(xiàn)通用協(xié)程池,需要的朋友可以參考下

代碼倉庫

goroutine-pool

golang的協(xié)程管理

golang協(xié)程機(jī)制很方便的解決了并發(fā)編程的問題,但是協(xié)程并不是沒有開銷的,所以也需要適當(dāng)限制一下數(shù)量。

不使用協(xié)程池的代碼(示例代碼使用chan實(shí)現(xiàn),代碼略啰嗦)

func (p *converter) upload(bytes [][]byte) ([]string, error) {
  ch := make(chan struct{}, 4)
  wg := &sync.WaitGroup{}
  wg.Add(len(bytes))
  ret := make([]string, len(bytes))
  // 上傳
  for index, item := range bytes {
    ch <- struct{}{}
    go func(index int, imageData []byte) {
      defer func() {
        wg.Done()
        <-ch
      }()
      link, err := qiniu.UploadBinary(imageData, fmt.Sprintf("%d.png", time.Now().UnixNano()))
      if err != nil {
        log.Println("上傳圖片失敗", err.Error())
        return
      }
      ret[index] = link
    }(index, item)
  }
  wg.Wait()
  return ret, nil
}

需要實(shí)現(xiàn)的需求有兩個(gè):

限制最大協(xié)程數(shù),本例為4

等待所有協(xié)程完成,本例為bytes切片長度

使用協(xié)程池的代碼

func (p *converter) upload(bytes [][]byte) ([]string, error) {
  ret := make([]string, len(bytes))
  pool := goroutine_pool.New(4, len(bytes))

  for index, item := range bytes {
    index := index
    item := item
    pool.Submit(func() {
      link, err := qiniu.UploadBinary(item, fmt.Sprintf("%d.png", time.Now().UnixNano()))
      if err != nil {
        log.Println("上傳圖片失敗", err.Error())
        return
      }

      ret[index] = link
    })
  }
  pool.Wait()
  return ret, nil
}

可以看到最大的區(qū)別是只需要關(guān)注業(yè)務(wù)邏輯即可,并發(fā)控制和等待都已經(jīng)被協(xié)程池接管

總結(jié)

以上所述是小編給大家介紹的golang 40行代碼實(shí)現(xiàn)通用協(xié)程池,希望對(duì)大家有所幫助,如果大家有任何疑問請(qǐng)給我留言,小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持!

相關(guān)文章

  • Go語言實(shí)現(xiàn)LRU算法的核心思想和實(shí)現(xiàn)過程

    Go語言實(shí)現(xiàn)LRU算法的核心思想和實(shí)現(xiàn)過程

    這篇文章主要介紹了Go語言實(shí)現(xiàn)LRU算法的核心思想和實(shí)現(xiàn)過程,LRU算法是一種常用的緩存淘汰策略,它的核心思想是如果一個(gè)數(shù)據(jù)在最近一段時(shí)間內(nèi)沒有被訪問到,那么在將來它被訪問的可能性也很小,因此可以將其淘汰,感興趣想要詳細(xì)了解可以參考下文
    2023-05-05
  • jenkins構(gòu)建go及java項(xiàng)目的方法

    jenkins構(gòu)建go及java項(xiàng)目的方法

    這篇文章主要介紹了jenkins構(gòu)建go及java項(xiàng)目,本文通過圖文實(shí)例相結(jié)合給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值了,需要的朋友可以參考下
    2021-04-04
  • 詳解golang各種類型是如何進(jìn)行比較的

    詳解golang各種類型是如何進(jìn)行比較的

    在日常開發(fā)中,比較操作是最常用的基本操作之一,可以用來判斷變量之間是否相等或者對(duì)應(yīng)的大小關(guān)系,比較操作對(duì)于排序、查找和集合數(shù)據(jù)結(jié)構(gòu)的實(shí)現(xiàn)至關(guān)重要,本文將深入解析golang各種類型是如何進(jìn)行比較的,需要的朋友可以參考下
    2024-01-01
  • Go語言接口與多態(tài)詳細(xì)介紹

    Go語言接口與多態(tài)詳細(xì)介紹

    Go語言的接口類型是一組方法定義的集合,它體現(xiàn)了多態(tài)性、高內(nèi)聚和低耦合的設(shè)計(jì)思想,接口通過interface關(guān)鍵字定義,無需實(shí)現(xiàn)具體方法,任何實(shí)現(xiàn)了接口所有方法的類型即視為實(shí)現(xiàn)了該接口,感興趣的朋友一起看看吧
    2024-09-09
  • GO使用阿里云,解決go get下載項(xiàng)目慢或無法下載的情況

    GO使用阿里云,解決go get下載項(xiàng)目慢或無法下載的情況

    這篇文章主要介紹了GO使用阿里云,解決go get下載項(xiàng)目慢或無法下載的情況,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2024-01-01
  • Go Comparable Type原理深入解析

    Go Comparable Type原理深入解析

    這篇文章主要為大家介紹了Go Comparable Type原理深入解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-01-01
  • 最新評(píng)論