本例來自于《go語言實戰(zhàn)》,從這個例題開始助琐，我們不斷迭代关筒，不斷優(yōu)化胚宦，做出我們想要的程序。
eg1:
'''package main
import (
"fmt"
"sync"
)
func main() {
var wg sync.WaitGroup
wg.Add(2)
fmt.Println("Start sub goroutines")
go func() {
for count :=0; count <3; count++{
for char:='a';char<'a'+26;char++{
fmt.Printf("%c",char)
}
}
wg.Done()
}()
go func() {
for count :=0; count <3; count++{
for char:='A';char<'A'+26;char++{
fmt.Printf("%c",char)
}
}
wg.Done()
}()
wg.Wait()
fmt.Println()
fmt.Println("main goroutine over")
}
'''
由于并發(fā)程序的緣故锻梳，導致結(jié)果每次都不一樣，輸出大致結(jié)果如下：
Start sub goroutines
ABCDEFGHIJKLMNOPQRSTUVWXabcdefghYZABCDEijklmnopqrFGHstuvwxyIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVWXYZzabcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz
main goroutine over
中間的匿名函數(shù)明顯的我們要提出來净捅，做成一個獨立的函數(shù)疑枯。那就這么干，看看會出現(xiàn)什么情況蛔六。
eg2:
package main
import (
"fmt"
"sync"
)
func main() {
var wg sync.WaitGroup
wg.Add(2)
fmt.Println("Start sub goroutines")
go printer('a',wg)
go printer('A',wg)
wg.Wait()
fmt.Println()
fmt.Println("main goroutine over")
}
func printer(prefix rune,wg sync.WaitGroup) {
go func() {
for count := 0; count < 3; count++ {
for char := prefix; char < prefix+26; char++ {
fmt.Printf("%c", char)
}
}
wg.Done()
}()
}
代碼看起來干凈多了荆永，但是效果呢？我們看看運行結(jié)果国章。
fatal error: all goroutines are asleep - deadlock!
goroutine 1 [semacquire]:
sync.runtime_Semacquire(0xc00004c088)
C:/Go/src/runtime/sema.go:56 +0x40
sync.(*WaitGroup).Wait(0xc00004c080)
C:/Go/src/sync/waitgroup.go:130 +0x6b
main.main()
E:/mygo/goaction/goRoutine/goroutine.go:15 +0x10e
Start sub goroutines
abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvabcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyzwxyzabcdefghijklmnopabcdefghqrstuvwijklmnoxyzpqrstuvwxyz
Process finished with exit code 2
what?怎么會這樣具钥。我們仔細看看，通過E:/mygo/goaction/goRoutine/goroutine.go:15 +0x10e的提示液兽，我們發(fā)現(xiàn)可以看到骂删，問題出在wg.wait()。為什么？因為永遠等不到wg的計數(shù)為0. wg的計數(shù)器的減少是由 wg.done()完成的桃漾，這一句語法也沒有問題坏匪，問題在哪里呢？因為是值傳遞撬统，不是應(yīng)用傳遞适滓，導致出現(xiàn)錯誤。把函數(shù)的形式參數(shù)修改為指針恋追，調(diào)用的時候直接取wg的地址OK了凭迹。直接看代碼
package main
import (
"fmt"
"sync"
)
func main() {
var wg sync.WaitGroup
wg.Add(2)
fmt.Println("Start sub goroutines")
go printer('a',&wg)
go printer('A',&wg)
wg.Wait()
fmt.Println()
fmt.Println("main goroutine over")
}
func printer(prefix rune,wg *sync.WaitGroup) {
go func() {
for count := 0; count < 3; count++ {
for char := prefix; char < prefix+26; char++ {
fmt.Printf("%c", char)
}
}
wg.Done()
}()
}
結(jié)果沒問題。
這段代碼看起來沒問題了苦囱，如果我不想在每個子goroutine中輸出嗅绸，而是要集中統(tǒng)一輸出結(jié)果又該怎么做呢？對于go語言撕彤，當然要選擇channel.該怎么做呢鱼鸠？下回分解。
