婷婷综合国产,91蜜桃婷婷狠狠久久综合9色 ,九九九九九精品,国产综合av

主頁 > 知識庫 > Go并發:使用sync.WaitGroup實現協程同步方式

Go并發:使用sync.WaitGroup實現協程同步方式

熱門標簽:阿克蘇地圖標注 外呼系統用什么卡 涿州代理外呼系統 電話機器人軟件免費 外呼系統顯本地手機號 評價高的400電話辦理 百度地圖標注后傳給手機 壽光微信地圖標注 excel地圖標注分布數據

經??吹接腥藭柸绾蔚却鲄f程中創建的協程執行完畢之后再結束主協程,例如如下代碼:

package main
import (
    "fmt"
)
func main() {
    go func() {
        fmt.Println("Goroutine 1")
    }()
    go func() {
        fmt.Println("Goroutine 2")
    }()
}

執行以上代碼很可能看不到輸出,因為有可能這兩個協程還沒得到執行主協程已經結束了,而主協程結束時會結束所有其他協程。

解決辦法是可以在main函數結尾加上等待:

package main
import (
    "fmt"
    "time"
)
func main() {
    go func() {
        fmt.Println("Goroutine 1")
    }()
    go func() {
        fmt.Println("Goroutine 2")
    }()
    time.Sleep(time.Second * 1) // 睡眠1秒,等待上面兩個協程結束
}

這并不是完美的解決方法,如果這兩個協程中包含復雜的操作,可能很耗時間,就無法確定需要睡眠多久,當然可以用管道實現同步:

package main
import (
    "fmt"
)
func main() {
    ch := make(chan struct{})
    count := 2 // count 表示活動的協程個數
    go func() {
        fmt.Println("Goroutine 1")
        ch - struct{}{} // 協程結束,發出信號
    }()
    go func() {
        fmt.Println("Goroutine 2")
        ch - struct{}{} // 協程結束,發出信號
    }()
    for range ch {
        // 每次從ch中接收數據,表明一個活動的協程結束
        count--
        // 當所有活動的協程都結束時,關閉管道
        if count == 0 {
            close(ch)
        }
    }
}

上面的解決方案是比較完美的方案,但是Go提供了更簡單的方法——使用sync.WaitGroup。

WaitGroup顧名思義,就是用來等待一組操作完成的。

WaitGroup內部實現了一個計數器,用來記錄未完成的操作個數,它提供了三個方法,Add()用來添加計數。

Done()用來在操作結束時調用,使計數減一。

Wait()用來等待所有的操作結束,即計數變為0,該函數會在計數不為0時等待,在計數為0時立即返回。

package main
import (
    "fmt"
    "sync"
)
func main() {
    var wg sync.WaitGroup
    wg.Add(2) // 因為有兩個動作,所以增加2個計數
    go func() {
        fmt.Println("Goroutine 1")
        wg.Done() // 操作完成,減少一個計數
    }()
    go func() {
        fmt.Println("Goroutine 2")
        wg.Done() // 操作完成,減少一個計數
    }()
    wg.Wait() // 等待,直到計數為0
}

可見用sync.WaitGroup是最簡單的方式。

補充:Golang 中使用WaitGroup的那點坑

sync.WaitGroup對于Golang開發者來說并不陌生,其經常作為多協程之間同步的一種機制。用好它勢必會讓你事半功倍,但是一旦錯用將引發問題。

關于WaitGroup的使用網上有很多例子,在此就不做介紹了,我想說的是我在項目中使用WaitGroup遇到的坑。

在項目中,因為服務器有同步需求, 所以直接使用了WaitGroup,但是未考慮使用場景,結果在項目上線之后,高峰期的時候客戶端經常出現卡頓,經過多方查找,才發現如果使用WaitGroup的時候,未啟動單獨的goroutine,那么極有可能造成主線程的阻塞,

所以我做了下面的測試(測試中,我把WaitGroup置于協程內):

import (
 "fmt"
 "sync"
 "time"
)
 
func main() {
    fmt.Println("main-1")
 testW()
 fmt.Println("main-2")
 time.Sleep(time.Duration(15) * time.Second) 
}
 
func testW() {
 fmt.Println("testW-1")
 go func() {
  var wg sync.WaitGroup
  fmt.Println("testW-2")
  testW1(wg)
  fmt.Println("testW-5")
  wg.Wait()
  fmt.Println("testW-6")
 }()
}
 
func testW1(wg *sync.WaitGroup) {
 wg.Add(1)
 fmt.Println("testW-3")
 time.AfterFunc(time.Second*5, func() {
  wg.Done()
 })
 fmt.Println("testW-4") 
}

輸出為:

main-1

testchan-1

main-2

testchan-2

testchan-3

testchan-4

testchan-5

// 過5秒

testchan-6

總結:

將WaitGroup用于goroutine內,不會導致主線程的阻塞,同樣可以實現同步的效果。

以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方,望不吝賜教。

您可能感興趣的文章:
  • Golang 實現分片讀取http超大文件流和并發控制
  • Go 并發控制context實現原理剖析(小結)
  • 解決Golang 中使用WaitGroup的那點坑
  • Go語言WaitGroup使用時需要注意的坑
  • Golang中的sync.WaitGroup用法實例
  • Go并發控制WaitGroup的使用場景分析

標簽:梅河口 雞西 重慶 汕頭 蘭州 吐魯番 欽州 銅川

巨人網絡通訊聲明:本文標題《Go并發:使用sync.WaitGroup實現協程同步方式》,本文關鍵詞  并發,使用,sync.WaitGroup,實現,;如發現本文內容存在版權問題,煩請提供相關信息告之我們,我們將及時溝通與處理。本站內容系統采集于網絡,涉及言論、版權與本站無關。
  • 相關文章
  • 下面列出與本文章《Go并發:使用sync.WaitGroup實現協程同步方式》相關的同類信息!
  • 本頁收集關于Go并發:使用sync.WaitGroup實現協程同步方式的相關信息資訊供網民參考!
  • 推薦文章
    婷婷综合国产,91蜜桃婷婷狠狠久久综合9色 ,九九九九九精品,国产综合av
    亚洲国产视频在线| 久草这里只有精品视频| 99久久精品国产网站| 欧美日韩在线一区二区| 九九久久精品视频| 日韩福利视频网| 亚洲男人的天堂在线aⅴ视频| 秋霞电影一区二区| 欧美国产精品专区| 欧美做爰猛烈大尺度电影无法无天| 久久精品国产色蜜蜜麻豆| 中文字幕一区三区| 99国产精品久久久| 麻豆精品视频在线| 中文字幕一区二区日韩精品绯色| 欧美视频中文一区二区三区在线观看| 激情国产一区二区| 久久99国内精品| 日韩女优毛片在线| 国产成a人无v码亚洲福利| 国产专区综合网| 国产乱子伦视频一区二区三区 | 精品伦理精品一区| 欧美日韩一区二区三区视频| 国产精品情趣视频| 欧美激情一区二区在线| 自拍偷拍国产精品| 亚洲精品国产a| 日韩午夜小视频| 亚洲免费在线观看视频| 国产精品卡一卡二卡三| 国产精品久久国产精麻豆99网站| 国产偷国产偷亚洲高清人白洁| 国产日韩欧美麻豆| 亚洲精品视频一区二区| 午夜伦欧美伦电影理论片| 天天操天天干天天综合网| 麻豆精品在线看| 成人午夜激情在线| 日本精品免费观看高清观看| 欧美日韩精品免费观看视频| 精品免费一区二区三区| 欧美韩国日本不卡| 亚洲成国产人片在线观看| 欧美一区二区私人影院日本| 国产成人午夜电影网| 亚洲一区二区在线免费看| 欧美激情一区不卡| |精品福利一区二区三区| 亚洲视频每日更新| 亚洲永久精品大片| 久久精品国产一区二区| 精品午夜久久福利影院| a美女胸又www黄视频久久| 欧美视频一区二区三区四区| 国产免费成人在线视频| 日本成人在线网站| 日韩精品一区二区在线观看| 精品免费99久久| 亚洲图片激情小说| 91在线精品一区二区三区| 亚洲一区二区三区自拍| 久久狠狠亚洲综合| 99精品在线观看视频| 日韩一区二区免费在线电影| 久久国产精品一区二区| 色综合久久久久网| 精品国产91洋老外米糕| 亚洲第一电影网| 高清视频一区二区| 制服丝袜日韩国产| 国产精品午夜在线| 久久99精品久久久久久久久久久久 | 欧美国产激情二区三区| 中文字幕一区二区三区四区不卡| 日日骚欧美日韩| 97aⅴ精品视频一二三区| 精品免费视频一区二区| 亚洲色图在线看| 国产a精品视频| 久久久99精品久久| 男女视频一区二区| 欧美另类高清zo欧美| 一级女性全黄久久生活片免费| 成人福利电影精品一区二区在线观看 | 午夜影院在线观看欧美| 99热精品一区二区| 欧美国产1区2区| 国产成人免费视| 久久精品人人做| 成人午夜av影视| 中文一区在线播放| 成人av在线网站| 日韩美女精品在线| 色先锋资源久久综合| 一区二区三区四区在线播放| 欧美亚洲一区二区在线| 视频一区二区欧美| 欧美一区二区精美| 奇米色一区二区| 精品乱码亚洲一区二区不卡| 麻豆91在线播放免费| 久久综合久久综合亚洲| 国产一区二区美女| 中文字幕精品—区二区四季| 99久久久国产精品免费蜜臀| 亚洲视频在线一区| 日本韩国欧美一区| 亚洲综合激情小说| 欧美高清视频在线高清观看mv色露露十八| 亚洲欧美激情视频在线观看一区二区三区| 成人中文字幕在线| 一区二区三区免费在线观看| 精品一区二区三区在线播放视频| 欧美视频在线一区| 美国十次综合导航| 精品少妇一区二区三区在线视频| 国产999精品久久久久久| 精品久久久久久久久久久久久久久| 蜜桃久久av一区| 日本一区免费视频| 欧美日韩精品免费观看视频| 日韩精品一级二级| 久久欧美一区二区| 成人动漫av在线| aaa欧美大片| 日本中文一区二区三区| 久久久久久久久久久久久女国产乱 | 成人av一区二区三区| 中文字幕制服丝袜成人av| 欧美羞羞免费网站| 亚洲丶国产丶欧美一区二区三区| 欧美va在线播放| 色婷婷综合激情| 免费观看一级特黄欧美大片| 国产精品全国免费观看高清| 在线播放91灌醉迷j高跟美女 | 国产成人综合亚洲91猫咪| 亚洲宅男天堂在线观看无病毒| 精品不卡在线视频| 欧美日韩精品综合在线| 欧美日韩国产经典色站一区二区三区 | 天天综合色天天综合色h| 日韩精品一区二区三区在线播放 | 亚洲一二三区视频在线观看| 欧美不卡在线视频| 欧美性生活久久| 99热在这里有精品免费| 国模套图日韩精品一区二区 | 美国三级日本三级久久99| 亚洲免费在线观看视频| 久久久电影一区二区三区| 欧美一级高清片在线观看| 欧美性大战久久久久久久蜜臀| 国产一区 二区| 免费在线一区观看| 亚洲主播在线播放| 亚洲精品视频在线| 国产精品久久久久久久久免费丝袜 | 国产一区二区三区最好精华液| 亚洲一区二区三区三| 亚洲男人天堂av| 国产精品动漫网站| 国产精品狼人久久影院观看方式| 久久久久久久精| 久久先锋资源网| 欧美成人在线直播| 欧美tickling挠脚心丨vk| 伊人一区二区三区| 亚洲女性喷水在线观看一区| 国产精品欧美一区喷水| 26uuu精品一区二区在线观看| 91精品国产黑色紧身裤美女| 欧美性猛片xxxx免费看久爱| 不卡视频一二三四| 99精品一区二区| 在线视频中文字幕一区二区| 在线观看国产日韩| 欧美视频你懂的| 欧美日韩成人激情| 在线亚洲高清视频| 欧美日韩亚洲综合一区二区三区| 欧美亚洲日本一区| 91网站在线播放| 日本精品免费观看高清观看| 欧美性生活影院| 这里是久久伊人| 久久嫩草精品久久久精品 | 亚洲一区二区免费视频| 夜夜亚洲天天久久| 日韩一区精品视频| 黑人巨大精品欧美黑白配亚洲| 国产成人亚洲综合色影视| 国产精品911| 99久久久无码国产精品| 欧美手机在线视频| 精品国内二区三区| 亚洲欧美日韩国产综合在线| 亚洲成av人片在线观看无码| 黄网站免费久久|