主頁 > 知識庫 > golang coroutine 的等待與死鎖用法

golang coroutine 的等待與死鎖用法

熱門標(biāo)簽:excel地圖標(biāo)注分布數(shù)據(jù) 外呼系統(tǒng)用什么卡 外呼系統(tǒng)顯本地手機(jī)號 壽光微信地圖標(biāo)注 百度地圖標(biāo)注后傳給手機(jī) 評價(jià)高的400電話辦理 涿州代理外呼系統(tǒng) 電話機(jī)器人軟件免費(fèi) 阿克蘇地圖標(biāo)注

直接上代碼:

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é)

標(biāo)簽:雞西 梅河口 汕頭 吐魯番 重慶 欽州 蘭州 銅川

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《golang coroutine 的等待與死鎖用法》,本文關(guān)鍵詞  golang,coroutine,的,等待,與,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《golang coroutine 的等待與死鎖用法》相關(guān)的同類信息!
  • 本頁收集關(guān)于golang coroutine 的等待與死鎖用法的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章