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