怎么在golang中利用并發(fā)實現(xiàn)協(xié)程同步

怎么在golang中利用并發(fā)實現(xiàn)協(xié)程同步？針對這個問題，這篇文章詳細(xì)介紹了相對應(yīng)的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

Java 中有一系列的線程同步的方法，go 里面有 goroutine（協(xié)程），先看下下面的代碼執(zhí)行的結(jié)果是什么呢？

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

執(zhí)行以上代碼很可能看不到輸出。

因為有可能這兩個協(xié)程還沒得到執(zhí)行，主協(xié)程就已經(jīng)結(jié)束了，而主協(xié)程結(jié)束時會結(jié)束所有其他協(xié)程，所以導(dǎo)致代碼運行的結(jié)果什么都沒有。

估計不少新接觸 go 的童鞋都會對此郁悶?，可能會問那么該如何等待主協(xié)程中創(chuàng)建的協(xié)程執(zhí)行完畢之后再結(jié)束主協(xié)程呢？

下面說幾種可以解決的方法：

Sleep 一段時間

在 main 方法退出之前 sleep 一段時間就可能會出現(xiàn)結(jié)果了，如下代碼：

 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秒，等待上面兩個協(xié)程結(jié)束
}

這兩個簡單的協(xié)程執(zhí)行消耗的時間很短的，所以你會發(fā)現(xiàn)現(xiàn)在就有結(jié)果出現(xiàn)了。

Goroutine 1
Goroutine 2

為什么上面我要說 “可能會出現(xiàn)” ？

因為 sleep 這個時間目前是設(shè)置的 1s，如果我這兩個協(xié)程里面執(zhí)行了很復(fù)雜的邏輯操作（時間大于 1s），那么就會發(fā)現(xiàn)依舊也是無結(jié)果打印出來的。

那么就可以發(fā)現(xiàn)這種方式得到問題所在了：我們無法確定需要睡眠多久

上面那種方式有問題，go 里面其實也可以用管道來實現(xiàn)同步的。

管道實現(xiàn)同步

那么用管道怎么實現(xiàn)同步呢？show code：

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

這種方式是一種比較完美的解決方案， goroutine / channel 它們也是在 go 里面經(jīng)常搭配在一起的一對。

sync.WaitGroup

其實 go 里面也提供了更簡單的方式 —— 使用 sync.WaitGroup。

WaitGroup 顧名思義，就是用來等待一組操作完成的。WaitGroup 內(nèi)部實現(xiàn)了一個計數(shù)器，用來記錄未完成的操作個數(shù)，它提供了三個方法：

• Add() 用來添加計數(shù)

• Done() 用來在操作結(jié)束時調(diào)用，使計數(shù)減一

• Wait() 用來等待所有的操作結(jié)束，即計數(shù)變?yōu)?0，該函數(shù)會在計數(shù)不為 0 時等待，在計數(shù)為 0 時立即返回

繼續(xù) show code：

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

golang適合做什么

golang可以做服務(wù)器端開發(fā)，但golang很適合做日志處理、數(shù)據(jù)打包、虛擬機(jī)處理、數(shù)據(jù)庫代理等工作。在網(wǎng)絡(luò)編程方面，它還廣泛應(yīng)用于web應(yīng)用、API應(yīng)用等領(lǐng)域。

關(guān)于怎么在golang中利用并發(fā)實現(xiàn)協(xié)程同步問題的解答就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關(guān)注億速云行業(yè)資訊頻道了解更多相關(guān)知識。