goroutine只是由官方實現的超級"線程池"而已,每個實例4-5kb的棧內存占用和用于實現機制而大幅減少的創建和銷毀開銷。
并發不是并行(多CPU): Concurrency Is Not Parallelism
并發主要由切換時間片來實現"同時"運行,并行則是直接利用多核實現多線程的運行,但Go可以設置使用核數,以發揮多核計算機的能力。
package mainimport ( "fmt" "time")func Go() { fmt.Println("1234...") }func main() { go Go() //go關鍵字構成多線程 time.Sleep(2 * time.Second) //主程序睡眠2s}
Goroutine 奉行通過 通信來共享內存 ,而不是 共享內存來通信 。
Channel
package mainimport ( "fmt")func main() { //主程序 c := make(chan bool) //初始化一個chan類型 go func() { //子程序 fmt.Println("123...") //執行主程序 c <- true //通過<-存入bool類型到chan中 }()fmt.Println(1) //程序執行步驟:1stread_chan := <-c //<-c 從chan中讀取bool,程序執行步驟:2ndfmt.Println(read_chan) //程序執行步驟:3rd}/*output1st 1 2nd 123...3rd true*/
注意以上程序的執行順序(channel無緩存時):先執行讀取操作 c<-c ,因為channel中沒有值,所以程序發生阻塞,此時執行chanel 寫操作 ,然后再執行讀操作。
package mainimport ( "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 mainimport ( "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}/*output1 22 123...2 123 true3 3 */
設置緩存后,程序為異步,讀,寫操作同時完成,當讀取channal中無數據時,也不會造成堵塞,因為與此同時,寫操作也將發生。
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持VEVB武林網。
新聞熱點
疑難解答