直接上代碼:
1. 第一種情況
如果沒有select{}, main 主線程不會等待coroutine運(yùn)行,導(dǎo)致coroutine得不到機(jī)會運(yùn)行。
You are requesting eventual scheduling (using the two go statements)
of two goroutines and then you exit main without giving the scheduler
a chance to do anything.
有了select, 程序正常運(yùn)行。
package main
import (
"fmt"
"time"
)
func main() {
go func1()
go func2()
select{}
}
func func1() {
for{
fmt.Println("here1")
time.Sleep(10 * time.Minute)
}
}
func func2() {
for{
fmt.Println("here2")
time.Sleep(10 * time.Minute)
}
}
2. coroutine有機(jī)會運(yùn)行
但是會發(fā)生死鎖, fatal error: all goroutines are asleep - deadlock!
The goroutine executing func1 exited, ditto for func2. The main goroutine is blocked with no hope to recover while no other goroutine can be scheduled.
package main
import (
"fmt"
//"time"
)
func main() {
go func1()
go func2()
select {
}
}
func func1() {
fmt.Println("here1")
}
func func2() {
fmt.Println("here2")
}
3. 第三種情況, 正常運(yùn)行
package main
import (
"fmt"
)
var c = make(chan int, 2)
func main() {
go func1()
go func2()
-c
-c
fmt.Println("ok")
}
func func1() {
fmt.Println("here1")
c - 1
}
func func2() {
fmt.Println("here2")
c - 1
}
4. 實(shí)現(xiàn)上面的目的的另外一種方法:
var wg sync.WaitGroup
var urls = []string{
"http://www.golang.org/",
"http://www.google.com/",
"http://www.somestupidname.com/",
}
for _, url := range urls {
// Increment the WaitGroup counter.
wg.Add(1)
// Launch a goroutine to fetch the URL.
go func(url string) {
// Decrement the counter when the goroutine completes.
defer wg.Done()
// Fetch the URL.
http.Get(url)
}(url)
}
// Wait for all HTTP fetches to complete.
wg.Wait()
補(bǔ)充:golang中死鎖的情況分析
Golang關(guān)于channel死鎖情況的匯總以及解決方案
直接讀取空channel的死鎖
當(dāng)一個(gè)channel中沒有數(shù)據(jù),而直接讀取時(shí),會發(fā)生死鎖:
func main() {
q := make(chan int, 2)
-q
}
錯(cuò)誤提示:
fatal error: all goroutines are asleep - deadlock!
goroutine 1 [chan receive]:
main.main()
/home/erick/Desktop/Book/Parallel/final.go:159 +0x4d
exit status 2
上述代碼中,創(chuàng)建了一個(gè)2個(gè)容量的channel,直接讀取發(fā)生了死鎖情況。
修正方案,使用select方法阻止,在default中放置默認(rèn)處理方式:
func main() {
q := make(chan int, 2)
select {
case v := -q:
fmt.Println(v)
default:
fmt.Println("nothing in channel")
}
}
輸出:
nothing in channel
過度寫入數(shù)據(jù)造成的死鎖
寫入數(shù)據(jù)超過channel的容量,也會造成死鎖:
func main() {
q := make(chan int, 2)
q - 1
q - 2
q - 3
}
解決方案,與寫入的方式一樣,使用select方法阻止,在default中放置默認(rèn)處理方式:
func main() {
q := make(chan int, 2)
q - 1
q - 2
select {
case q - 3:
fmt.Println("ok")
default:
fmt.Println("wrong")
}
}
向已經(jīng)關(guān)閉的channel中寫入數(shù)據(jù)
這種造成的不是死鎖,而是產(chǎn)生panic。
func main() {
q := make(chan int, 2)
close(q)
q - 1
}
代碼錯(cuò)誤:
panic: send on closed channel
goroutine 1 [running]:
main.main()
/home/erick/Desktop/Book/Parallel/final.go:154 +0x63
exit status 2
解決方案:只有別向已經(jīng)關(guān)閉的channel寫數(shù)據(jù)。。。。
但是,可以從已經(jīng)關(guān)閉的channel中讀取數(shù)據(jù):
func main() {
q := make(chan int, 3)
q - 1
q - 2
q - 3
close(q)
for v := range q {
fmt.Println(v)
}
下面開始講解goroutine的讀寫
package main
import "fmt"
func main() {
c:=make(chan string)
go func() {
c-"hello"
}()
fmt.Println(-c)
}
上面這個(gè)是對的
package main
import "fmt"
func main() {
c:=make(chan string)
fmt.Println(-c)
go func() {
c-"hello"
}()
}
上面這個(gè)是錯(cuò)的,會發(fā)生死鎖,因?yàn)槌绦驎枞趂mt.Println(-c),并不會向下執(zhí)行。在該行發(fā)生了阻塞,以致于下面的代碼沒有機(jī)會執(zhí)行。因此可以總結(jié)寫在讀前,寫操作完成后才有讀操作。
總結(jié):
上述提到的死鎖,是指在程序的主線程中發(fā)生的情況,如果上述的情況發(fā)生在非主線程中,讀取或者寫入的情況是發(fā)生堵塞的,而不是死鎖。
實(shí)際上,阻塞情況省去了我們加鎖的步驟,反而是更加有利于代碼編寫,要合理的利用阻塞。。
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教。
您可能感興趣的文章:- 詳解Golang并發(fā)操作中常見的死鎖情形
- Go 語言中的死鎖問題解決
- Go語言死鎖與goroutine泄露問題的解決
- go select編譯期的優(yōu)化處理邏輯使用場景分析
- Django實(shí)現(xiàn)jquery select2帶搜索的下拉框
- Go語言使用select{}阻塞main函數(shù)介紹
- matplotlib之多邊形選區(qū)(PolygonSelector)的使用
- golang中的select關(guān)鍵字用法總結(jié)
- Go select 死鎖的一個(gè)細(xì)節(jié)