您好,登錄后才能下訂單哦!
goroutine只是由官方實現的超級"線程池"而已,每個實例4-5kb的棧內存占用和用于實現機制而大幅減少的創建和銷毀開銷。
并發不是并行(多CPU): Concurrency Is Not Parallelism
并發主要由切換時間片來實現"同時"運行,并行則是直接利用多核實現多線程的運行,但Go可以設置使用核數,以發揮多核計算機的能力。
package main import ( "fmt" "time" ) func Go() { fmt.Println("1234...") } func main() { go Go() //go關鍵字構成多線程 time.Sleep(2 * time.Second) //主程序睡眠2s }
Goroutine 奉行通過 通信來共享內存 ,而不是 共享內存來通信 。
Channel
package main import ( "fmt" ) func main() { //主程序 c := make(chan bool) //初始化一個chan類型 go func() { //子程序 fmt.Println("123...") //執行主程序 c <- true //通過<-存入bool類型到chan中 }() fmt.Println(1) //程序執行步驟:1st read_chan := <-c //<-c 從chan中讀取bool,程序執行步驟:2nd fmt.Println(read_chan) //程序執行步驟:3rd } /*output 1st 1 2nd 123... 3rd true */
注意以上程序的執行順序(channel無緩存時):先執行讀取操作 c<-c ,因為channel中沒有值,所以程序發生阻塞,此時執行chanel 寫操作 ,然后再執行讀操作。
package main import ( "fmt" ) func main() { c := make(chan bool) //初始化一個chan類型 go func() { //go結合匿名函數,構造并發 fmt.Println("123...") //執行主程序 c <- true //通過<-存入bool類型到chan中 close(c) //關閉通道:必須明確在哪個地方關閉 }() for v := range c { //for循環chanel } } /*output 123... true */
package main import ( "fmt" ) func main() { //主程序 c := make(chan bool, 1) //初始化一個chan類型,緩存為2 go func() { //子程序 fmt.Println("123...") //執行主程序,執行步驟:2 c <- true //寫操作,執行步驟:2 }() fmt.Println(2) //執行步驟:1 fmt.Println(123, <-c) //讀操作,執行步驟:2 fmt.Println(3) //執行步驟:3 } /*output 1 2 2 123... 2 123 true 3 3 */
設置緩存后,程序為異步,讀,寫操作同時完成,當讀取channal中無數據時,也不會造成堵塞,因為與此同時,寫操作也將發生。
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。