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