golang并發編程的實現

 更新時間:2020-01-12 19:00:24   作者:佚名   我要評論(0)

go


main函數的執行本身就是一個協程,當使用go關鍵字的時候,就會創建一個新的協程
channel


channel 管道,用于在多個協程之間傳遞信號
無緩存管道


當對無

go

main函數的執行本身就是一個協程,當使用go關鍵字的時候,就會創建一個新的協程

channel

channel 管道,用于在多個協程之間傳遞信號

無緩存管道

當對無緩沖通道寫的時候,會一直阻塞等到某個協程對這個緩沖通道讀

阻塞場景:

  1. 通道中無數據,但執行讀通道。
  2. 通道中無數據,向通道寫數據,但無協程讀取。

綜上,無緩存通道的讀寫必須同時存在,且讀寫分別在兩個不同的協程

func main(){
  ch := make(chan int)
  
  go func(ch chan int){
    ch <-222
  }(ch)
  
  println(<-ch)
}

有緩沖管道

有緩存時可以向通道中寫入數據后直接返回,緩存中有數據時可以從通道中讀到數據直接返回,這時有緩存通道是不會阻塞的

阻塞場景:

  1. 通道的緩存無數據,但執行讀通道。
  2. 通道的緩存已經占滿,向通道寫數據,但無協程讀。

綜上,有緩沖通道的讀寫必須在兩個不同協程

func main() {
  ch := make(chan int, 1) //長度為1的緩沖管道也是有緩沖管道
  ch <- 333
  go func(ch chan int) {
    println(<-ch)
  }(ch)
  ch <- 333
}

sync.Mutex 和 sync.RwMutex

sync.Mutex 并發鎖,一次只可以加載一個并發鎖

sync.RwMutex 讀寫鎖,一次可以加載多個讀鎖和一個寫鎖。當寫鎖存在時候,不能再加載讀鎖和寫鎖

sync.WaitGroup

阻塞等待所有任務完成之后再繼續執行

WaitGroup在不方法中傳遞,需要傳指針

func main() {
  var wg sync.WaitGroup
  ch := make(chan int, 1000)
  for i := 0; i < 1000; i++ {
    wg.Add(1)
    go doSomething(i, &wg, ch)
  }
  wg.Wait()
  fmt.Println("all done")
  for i := 0; i < 1000; i++ {
    dd := <-ch
    fmt.Println("from ch:"+strconv.Itoa(dd))
  }
}

func doSomething(index int, wg *sync.WaitGroup, ch chan int) {
  defer wg.Done()
  fmt.Println("start done:" + strconv.Itoa(index))
  //time.Sleep(20 * time.Millisecond)
  ch <- index
}

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。

您可能感興趣的文章:

  • golang通過context控制并發的應用場景實現
  • golang并發ping主機的方法
  • gorm golang 并發連接數據庫報錯的解決方法
  • golang 并發安全Map以及分段鎖的實現方法
  • Golang實現對map的并發讀寫的方法示例
  • golang高并發的深入理解
  • golang基礎之Gocurrency并發
  • golang中sync.Map并發創建、讀取問題實戰記錄
  • 詳解Golang 中的并發限制與超時控制
  • golang實現并發數控制的方法
  • 如何利用Golang寫出高并發代碼詳解
  • Golang極簡入門教程(三):并發支持

相關文章

  • golang并發編程的實現

    golang并發編程的實現

    go main函數的執行本身就是一個協程,當使用go關鍵字的時候,就會創建一個新的協程 channel channel 管道,用于在多個協程之間傳遞信號 無緩存管道 當對無
    2020-01-12
  • python opencv實現信用卡的數字識別

    python opencv實現信用卡的數字識別

    本項目利用python以及opencv實現信用卡的數字識別 前期準備 導入工具包 定義功能函數 模板圖像處理 讀取模板圖像 cv2.imread(img) 灰度化處理 cv2
    2020-01-12
  • 2019年度web前端面試題總結(主要為Vue面試題)

    2019年度web前端面試題總結(主要為Vue面試題)

    畢業之后就在一直合肥小公司工作,沒有老司機、沒有技術氛圍,在技術的道路上我只能獨自摸索。老板也只會畫餅充饑,前途一片迷?床坏饺魏蜗M。于是乎,我果斷辭
    2020-01-12
  • 深入理解redux之compose的具體應用

    深入理解redux之compose的具體應用

    應用 最近給自己的react項目添加redux的時候,用到了redux中的compose函數,使用compose來增強store,下面是我在項目中的一個應用: import {createStore,apply
    2020-01-12
  • Java使用DateTimeFormatter實現格式化時間

    Java使用DateTimeFormatter實現格式化時間

    用掃描器獲取輸入的時間(年月日時分),這個時間的格式是常用的格式,然后格式化這個時間,把格式化的時間輸出到控制臺,可以在控制臺重復輸入時間.格式化的時間參考企業
    2020-01-12
  • Ranorex通過Python將報告發送到郵箱的方法

    Ranorex通過Python將報告發送到郵箱的方法

    Ranorex測試報告如何發送到郵箱在網上看了下,其實可以通過在Ranorex上或者VS調用編寫發送郵箱代碼就可以執行發送了,RX主要涉及到的開發語言是C++或者.NET。但是我
    2020-01-12
  • 通過實例解析JMM和Volatile底層原理

    通過實例解析JMM和Volatile底層原理

    這篇文章主要介紹了通過實例解析JMM和Volatile底層原理,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下 JMM和
    2020-01-11
  • 淺談pytorch卷積核大小的設置對全連接神經元的影響

    淺談pytorch卷積核大小的設置對全連接神經元的影響

    3*3卷積核與2*5卷積核對神經元大小的設置 #這里kerner_size = 2*5 class CONV_NET(torch.nn.Module): #CONV_NET類繼承nn.Module類 def __init__(self): super(
    2020-01-11
  • python如何獲取apk的packagename和activity

    python如何獲取apk的packagename和activity

    這篇文章主要介紹了python如何獲取apk的packagename和activity,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-01-11
  • 在pytorch中對非葉節點的變量計算梯度實例

    在pytorch中對非葉節點的變量計算梯度實例

    在pytorch中一般只對葉節點進行梯度計算,也就是下圖中的d,e節點,而對非葉節點,也即是c,b節點則沒有顯式地去保留其中間計算過程中的梯度(因為一般來說只有葉節點
    2020-01-11

最新評論

北京pk10直播盛源