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并發編程的實現
分享URL：http://vcdvsql.cn/article36/podipg.html

成都網站建設公司_創新互聯，為您提供手機網站建設、虛擬主機、網站營銷、網站內鏈、網站導航、建站公司

廣告

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