goroutine只是由官方實現(xiàn)的超級"線程池"而已,每個實例4-5kb的棧內(nèi)存占用和用于實現(xiàn)機制而大幅減少的創(chuàng)建和銷毀開銷。
并發(fā)不是并行(多CPU): Concurrency Is Not Parallelism
并發(fā)主要由切換時間片來實現(xiàn)"同時"運行,并行則是直接利用多核實現(xiàn)多線程的運行,但Go可以設置使用核數(shù),以發(fā)揮多核計算機的能力。
package main
import (
"fmt"
"time"
)
func Go() {
fmt.Println("1234...")
}
func main() {
go Go() //go關鍵字構成多線程
time.Sleep(2 * time.Second) //主程序睡眠2s
}
Goroutine 奉行通過 通信來共享內(nèi)存 ,而不是 共享內(nèi)存來通信 。
Channel
- Channel是goroutine溝通的橋梁,大都是阻塞同步的
- 通過make創(chuàng)建,close關閉(當程序簡單時,回自動關閉)
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í)行讀操作。
- Channel是引用類型
- 可以使用 for range 來迭代不斷操作channel
package main
import (
"fmt"
)
func main() {
c := make(chan bool) //初始化一個chan類型
go func() { //go結合匿名函數(shù),構造并發(fā)
fmt.Println("123...") //執(zhí)行主程序
c - true //通過-存入bool類型到chan中
close(c) //關閉通道:必須明確在哪個地方關閉
}()
for v := range c { //for循環(huán)chanel
}
}
/*output
123...
true
*/
- 可以設置單向(讀寫)或雙向通道--默認是雙向通道
- 可以設置緩存大?。J為0,阻塞),在未被填充前不會發(fā)生阻塞(異步),比如緩存20個,可以同時進行20個讀操作或者寫操作,注意 讀的操作先于寫的操作
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中無數(shù)據(jù)時,也不會造成堵塞,因為與此同時,寫操作也將發(fā)生。
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
您可能感興趣的文章:- 如何利用Golang寫出高并發(fā)代碼詳解
- Golang極簡入門教程(三):并發(fā)支持
- 詳解Golang 中的并發(fā)限制與超時控制
- golang中sync.Map并發(fā)創(chuàng)建、讀取問題實戰(zhàn)記錄
- golang實現(xiàn)并發(fā)數(shù)控制的方法
- golang高并發(fā)的深入理解