goroutine只是由官方實現的超級"線程池"而已,每個實例4-5kb的棧內存占用和用于實現機制而大幅減少的創(chuàng)建和銷毀開銷。
創(chuàng)新互聯建站主營民和網站建設的網絡公司,主營網站建設方案,app開發(fā)定制,民和h5微信小程序定制開發(fā)搭建,民和網站營銷推廣歡迎民和等地區(qū)企業(yè)咨詢
并發(fā)不是并行(多CPU): Concurrency Is Not Parallelism
并發(fā)主要由切換時間片來實現"同時"運行,并行則是直接利用多核實現多線程的運行,但Go可以設置使用核數,以發(fā)揮多核計算機的能力。
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...") //執(zhí)行主程序 c <- true //通過<-存入bool類型到chan中 }() fmt.Println(1) //程序執(zhí)行步驟:1st read_chan := <-c //<-c 從chan中讀取bool,程序執(zhí)行步驟:2nd fmt.Println(read_chan) //程序執(zhí)行步驟:3rd } /*output 1st 1 2nd 123... 3rd true */
注意以上程序的執(zhí)行順序(channel無緩存時):先執(zhí)行讀取操作 c<-c ,因為channel中沒有值,所以程序發(fā)生阻塞,此時執(zhí)行chanel 寫操作 ,然后再執(zhí)行讀操作。
package main import ( "fmt" ) func main() { c := make(chan bool) //初始化一個chan類型 go func() { //go結合匿名函數,構造并發(fā) fmt.Println("123...") //執(zhí)行主程序 c <- true //通過<-存入bool類型到chan中 close(c) //關閉通道:必須明確在哪個地方關閉 }() for v := range c { //for循環(huán)chanel } } /*output 123... true */
package main import ( "fmt" ) func main() { //主程序 c := make(chan bool, 1) //初始化一個chan類型,緩存為2 go func() { //子程序 fmt.Println("123...") //執(zhí)行主程序,執(zhí)行步驟:2 c <- true //寫操作,執(zhí)行步驟:2 }() fmt.Println(2) //執(zhí)行步驟:1 fmt.Println(123, <-c) //讀操作,執(zhí)行步驟:2 fmt.Println(3) //執(zhí)行步驟:3 } /*output 1 2 2 123... 2 123 true 3 3 */
設置緩存后,程序為異步,讀,寫操作同時完成,當讀取channal中無數據時,也不會造成堵塞,因為與此同時,寫操作也將發(fā)生。
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持創(chuàng)新互聯。