溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

golang基礎(chǔ)之Gocurrency并發(fā)

發(fā)布時(shí)間：2020-10-14 21:21:00 來源：腳本之家 閱讀：142 作者：failymao 欄目：編程語言

goroutine只是由官方實(shí)現(xiàn)的超級(jí)"線程池"而已，每個(gè)實(shí)例4-5kb的棧內(nèi)存占用和用于實(shí)現(xiàn)機(jī)制而大幅減少的創(chuàng)建和銷毀開銷。

并發(fā)不是并行（多CPU）:  Concurrency Is Not Parallelism

并發(fā)主要由切換時(shí)間片來實(shí)現(xiàn)"同時(shí)"運(yùn)行，并行則是直接利用多核實(shí)現(xiàn)多線程的運(yùn)行，但Go可以設(shè)置使用核數(shù)，以發(fā)揮多核計(jì)算機(jī)的能力。

  • 通過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 奉行通過 通信來共享內(nèi)存 ，而不是 共享內(nèi)存來通信 。

Channel

  • Channel是goroutine溝通的橋梁，大都是阻塞同步的
  • 通過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       //通過<-存入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無緩存時(shí))：先執(zhí)行讀取操作 c<-c ，因?yàn)閏hannel中沒有值，所以程序發(fā)生阻塞，此時(shí)執(zhí)行chanel 寫操作 ，然后再執(zhí)行讀操作。

  • Channel是引用類型
  • 可以使用 for range 來迭代不斷操作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       //通過<-存入bool類型到chan中
    close(c)       //關(guān)閉通道:必須明確在哪個(gè)地方關(guān)閉
  }()

  for v := range c {    //for循環(huán)chanel
  }
}

/*output
  123...
  true
*/
  • 可以設(shè)置單向(讀&寫)或雙向通道--默認(rèn)是雙向通道
  • 可以設(shè)置緩存大小（默認(rèn)為0，阻塞），在未被填充前不會(huì)發(fā)生阻塞（異步），比如緩存20個(gè)，可以同時(shí)進(jìn)行20個(gè)讀操作或者寫操作，注意 讀的操作先于寫的操作
package main
import (
  "fmt"
)

func main() { //主程序
  c := make(chan bool, 1)  //初始化一個(gè)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
  */

設(shè)置緩存后，程序?yàn)楫惒?，讀，寫操作同時(shí)完成，當(dāng)讀取channal中無數(shù)據(jù)時(shí)，也不會(huì)造成堵塞，因?yàn)榕c此同時(shí)，寫操作也將發(fā)生。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持億速云。

向AI問一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手