主頁(yè) > 知識(shí)庫(kù) > 詳解go語(yǔ)言的并發(fā)

詳解go語(yǔ)言的并發(fā)

熱門標(biāo)簽:寧波語(yǔ)音外呼系統(tǒng)公司 地圖標(biāo)注免費(fèi)定制店 湛江crm外呼系統(tǒng)排名 不封卡外呼系統(tǒng) 上海極信防封電銷卡價(jià)格 鄭州智能語(yǔ)音電銷機(jī)器人價(jià)格 重慶慶云企業(yè)400電話到哪申請(qǐng) 宿遷便宜外呼系統(tǒng)代理商 仙桃400電話辦理

1、啟動(dòng)go語(yǔ)言的協(xié)程

package main
 
import (
    "fmt"
    "runtime"
)
 
//runtime包
 
func main() {
    //runtime.Gosched() 用于讓出cpu時(shí)間片,讓出這段cpu的時(shí)間片,讓調(diào)度器重新分配資源
 
    //寫(xiě)一個(gè)匿名函數(shù)
    s := "test"
    go func(s string) {
        for i :=0;i 2;i++ {
            fmt.Println(s)
        }
    }(s)
 
    for i :=0;i 2;i ++ {
        //如果代碼跑到這里,調(diào)度器會(huì)把cpu資源釋放出來(lái),讓調(diào)度器重新分配cpu資源,可以分配到子協(xié)程,也可以重新分配到主協(xié)程
        runtime.Gosched()
        fmt.Println("123")
    }
}

2、runtime.Goexit()方法。立即終止當(dāng)前的協(xié)程

package main
 
import (
    "fmt"
    "runtime"
    "time"
)
 
//runtime.Goexit()   立即終止當(dāng)前的協(xié)程
func main() {
    go func() {
        defer fmt.Println("A.defter")
        func () {
            defer fmt.Println("B.defter")
            //立即終止當(dāng)前的協(xié)程,函數(shù)會(huì)走defer流程
            runtime.Goexit()
            fmt.Println("B")
        }()
        fmt.Println("A")
    }()
    for {
        time.Sleep(2 * time.Second)
    }
}
 
//不加runtime.Goexit()的結(jié)果
//B
//B.defter
//A
//A.defter
 
//加runtime.Goexit()的結(jié)果
//B.defter
//A.defter

3、runtime.GOMAXPROCS()表示go使用幾個(gè)cpu執(zhí)行代碼

package main
 
import (
    "fmt"
    "runtime"
)
 
func main() {
    //runtime.GOMAXPROCS() 表示讓go用幾個(gè)cpu做后面的事情
    n := runtime.GOMAXPROCS(4)
    fmt.Printf("%T--->%p---%d\n",n,n,n)
    for {
        go fmt.Print("0")
        fmt.Print(1)
    }
}

4、管道定義和創(chuàng)建管道

package main
 
import "fmt"
 
//go語(yǔ)言的協(xié)程運(yùn)行在相同的地址空間,因此訪問(wèn)共享內(nèi)存必須做好同步,處理好線程安全問(wèn)題
 
//go語(yǔ)言的協(xié)程之間的通信通過(guò)協(xié)程間通信來(lái)共享內(nèi)存,而不是共享內(nèi)存來(lái)通信
 
//channel是一個(gè)引用類型,用于多個(gè)協(xié)程間通信,內(nèi)部實(shí)現(xiàn)了同步,確保并發(fā)安全
 
 
//通道一般是結(jié)合協(xié)程一起使用
 
 
//如果通道中沒(méi)有數(shù)據(jù),后面你還去取數(shù)據(jù),則會(huì)報(bào)錯(cuò)
//fatal error: all goroutines are asleep - deadlock!
func main() {
    //test45_1 := make(chan int) //定義一個(gè)無(wú)緩沖的通道
 
    //無(wú)緩沖的通道是值在接受數(shù)據(jù)前沒(méi)有任何能力保存數(shù)據(jù),只能有一個(gè)數(shù)據(jù)進(jìn)入通道,進(jìn)入通道后,該通道就會(huì)加鎖,一直到這個(gè)數(shù)據(jù)被取出,鎖才釋放
 
    //無(wú)緩沖的通道有可能阻塞,如果我發(fā)送一個(gè)數(shù)據(jù)到通道,但是沒(méi)有協(xié)程來(lái)取數(shù)據(jù),則對(duì)于第一個(gè)協(xié)程就被阻塞
 
    //test45_2 := make(chan int,10)  //定義 一個(gè)有緩沖的通道
 
 
    //有緩沖的通道就是通道可以存儲(chǔ)指定數(shù)量的數(shù)據(jù),數(shù)據(jù)在里面也是有順序的,但是如果緩沖的數(shù)量滿了,這個(gè)通道也會(huì)是阻塞的
 
    //
    //test45_1 - 10   //發(fā)送數(shù)據(jù)到通道
    //- test45_1      //接受通道中的數(shù)據(jù),并丟棄
    //x := -test45_1 //從通道取值并賦值給x
    //x,ok := -test45_1  //ok檢查通道是否關(guān)閉或者是否為空
 
 
    //1、創(chuàng)建一個(gè)存放int類型的通道
    test45_1 := make(chan int)
 
    go func() {
        defer fmt.Println("子協(xié)程結(jié)束")
        fmt.Println("子協(xié)程正在運(yùn)行")
 
        test45_1 - 111
    }()
    //- test45_1
    //主協(xié)程從通道中取數(shù)據(jù)
    x := - test45_1
    fmt.Println(x)
    fmt.Println("主協(xié)程結(jié)束")
}

5、管道的緩沖

package main
 
import (
    "fmt"
    "time"
)
 
func main() {
    //無(wú)緩沖的通道,長(zhǎng)度為0就可以了,有緩沖的通道,這里設(shè)置為非0就可以了
    test46_1 := make(chan int,0)
 
    //%P是打印內(nèi)存地址,%T是打印變量的類型
    //fmt.Printf("長(zhǎng)度:%d--->容量:%d---->%P----%T",len(test46_1),cap(test46_1),test46_1,test46_1)
 
    go func() {
        defer fmt.Printf("子協(xié)程結(jié)束")
 
        for i :=0;i  3;i ++ {
            fmt.Println("子協(xié)程插入數(shù)據(jù)")
            test46_1 - i
            //fmt.Printf("長(zhǎng)度:%d--->容量:%d---->%P----%T",len(test46_1),cap(test46_1),test46_1,test46_1)
 
        }
 
    }()
 
    time.Sleep(2 * time.Second)
    for j :=0;j 3;j++ {
        fmt.Println("主協(xié)程取數(shù)據(jù)")
        num := - test46_1
        fmt.Println(num)
    }
}

6、關(guān)閉管道和接受關(guān)閉管道的信號(hào)

package main
 
import "fmt"
 
//close()方法,關(guān)閉通道的意思
 
func main() {
    test47_1 := make(chan int,4)
 
    go func() {
        for i :=0;i  10;i ++ {
            test47_1 - i
        }
        //這個(gè)的意思關(guān)閉通道test47_1
        close(test47_1)
    }()
 
    //for的寫(xiě)法,遍歷通道
    //for {
    //  //子協(xié)程關(guān)閉了通道,這里ok就可以接收到,這里就可以走到bread流程,ok這個(gè)參數(shù)表示通道是否關(guān)閉
    //  if data,ok := - test47_1;ok {
    //      fmt.Println(data)
    //  }else {
    //      break
    //  }
    //}
 
    //range的寫(xiě)法,遍歷通道
    for data := range test47_1 {
        fmt.Println(data)
    }
    fmt.Println("主協(xié)程結(jié)束")
}

7、只讀管道和只寫(xiě)管道和生產(chǎn)者和消費(fèi)者模型

package main
 
import (
    "fmt"
    "time"
)
 
//默認(rèn)情況下,管道是雙向的,既可以寫(xiě)入數(shù)據(jù),也可以讀出數(shù)據(jù)。go也可以定義單方向的管道,也就是說(shuō)只發(fā)送數(shù)據(jù),或者只寫(xiě)入數(shù)據(jù)
 
//可以把雙向的管道轉(zhuǎn)換為單向的管道,但是不能把單向的管道轉(zhuǎn)換為雙向的管道
 
//單方向的管道
 
func producter(out chan - int)  {
    defer close(out)
    for i := 0;i  10;i++ {
        out - i
    }
 
}
 
func consumer(int -chan int){
    for num := range int {
        fmt.Println(num)
    }
}
func main() {
 
    //1、定義管道
    //定義一個(gè)正常的管道
    //var test48_1 chan int
 
    //定義一個(gè)單向的只寫(xiě)的管道
    //var test48_2 chan - float32
 
    //定義一個(gè)單向的只讀的管道
    //var test48_3 - chan int
 
    //2、轉(zhuǎn)換管道
 
    //轉(zhuǎn)換正常管道為只寫(xiě)或者只讀的管道
    //定義一個(gè)正常的管道
    //test48_4 := make(chan int,3)
 
    //把一個(gè)正常的管道轉(zhuǎn)換為一個(gè)只寫(xiě)的管道
    //var write_only chan - int = test48_4
 
    //把一個(gè)正常的管道轉(zhuǎn)換為一個(gè)只讀的管道
    //var read_only - chan int = test48_4
 
 
 
    test48_5 := make(chan int,4)
 
    //啟動(dòng)生產(chǎn)者
    go producter(test48_5)
 
    //啟動(dòng)消費(fèi)者
    consumer(test48_5)
 
    time.Sleep(10 * time.Millisecond)
    fmt.Println("down")
 
}

8、Timer定時(shí)器

package main
 
import (
    "fmt"
    "time"
)
 
//定時(shí)器
 
//time.NewTimer()。時(shí)間到了,只執(zhí)行一次
//time.NewTicker(),周期性的執(zhí)行
 
func main() {
    //1、創(chuàng)建一個(gè)定時(shí)器,2s后定時(shí)器會(huì)將一個(gè)時(shí)間保存到一個(gè)C
    test49_1 := time.NewTimer(2 * time.Second)
 
    //打印系統(tǒng)當(dāng)前的時(shí)間
 
    t1 := time.Now()
 
    fmt.Printf("t1----->%v\n",t1)
 
    //從管道中取出C打印
 
    t2 := - test49_1.C
    fmt.Printf("t2----->%v\n",t2)
 
 
 
    //2、證明timer只執(zhí)行一次
    //test49_2 := time.NewTimer(4 * time.Second)
    //
    //for {
    //  c := - test49_2.C
    //  fmt.Println(c)
    //}
 
    //3、通過(guò)timer實(shí)現(xiàn)一個(gè)延時(shí)的功能
 
    //方式1
    //time.Sleep(2 * time.Second)
 
    //方式2
    //test49_3 := time.NewTimer(2 * time.Second)
 
    //方式3
 
    //-time.After(2 *time.Second)
 
    //4、停止定時(shí)器
    test49_4 := time.NewTimer(4 * time.Second)
    //子協(xié)程
    go func() {
        //這個(gè)意思是3s后才能取出來(lái)數(shù)據(jù)
        - test49_4.C
 
        fmt.Println("定時(shí)器時(shí)間到了")
    }()
 
    //關(guān)閉定時(shí)器
    stop := test49_4.Stop()
    if stop {
        fmt.Println("定時(shí)器已經(jīng)關(guān)閉")
    }
 
    //5、重置定時(shí)器
    test49_5 := time.NewTimer(4 * time.Second)
    //重置定時(shí)器為1s
    test49_5.Reset(1 * time.Second)
 
    for {
 
    }
    }

9、ticker定時(shí)器和關(guān)閉ticker定時(shí)器

package main
 
import (
    "fmt"
    "time"
)
 
//time.NewTicker(),定時(shí)器,響應(yīng)多次
 
func main() {
    //創(chuàng)建一個(gè)定時(shí)器,間隔1s
    test50_1 := time.NewTicker(time.Second)
    i := 0
    go func() {
        for {
            c := - test50_1.C
            fmt.Println(c)
            i ++
            fmt.Println(i)
        }
        }()
 
 
    for {
 
    }
}

10、select語(yǔ)句

package main
 
import (
    "fmt"
)
 
//go語(yǔ)言提供select關(guān)鍵字,用來(lái)監(jiān)聽(tīng)通道上的數(shù)據(jù)流動(dòng),語(yǔ)法和switch類似,區(qū)別是select必須要求每個(gè)case語(yǔ)句里必須是一個(gè)IO操作
 
//如果都能匹配到,則隨機(jī)選擇一個(gè)通道去跑,select是比較隨便的
 
func main() {
    //test51_1 := make(chan int,3)
    //select {
    //case - test51_1:
    //  fmt.Println("jja")
    ////如果從通道中可以讀出數(shù)據(jù),則執(zhí)行這里
    //case test51_1 - 1:
    //  fmt.Println("aa")
    ////如果通道中北寫(xiě)入數(shù)據(jù),則執(zhí)行號(hào)這里
    //default:
    //  fmt.Println("hah")
    ////如果上面都沒(méi)成功,則執(zhí)行這里
    //}
 
 
    test51_1 := make(chan int,1)
    test51_2 := make(chan string,1)
 
    go func() {
        //time.Sleep(2 * time.Second)
        test51_1 - 1
 
    }()
    go func() {
        test51_2 - "Hello World"
    }()
 
    select {
    case Value1:= - test51_1:
        fmt.Println(Value1)
    case Value2 := - test51_2:
        fmt.Println(Value2)
    }
    fmt.Println("結(jié)束")
 
}

11、協(xié)程同步鎖

package main
 
import (
    "fmt"
    "sync"
    "time"
)
 
//go語(yǔ)言的協(xié)程同步鎖,解決并發(fā)安全問(wèn)題
 
 
//取錢的例子
 
type Account struct {
    money int
    flag sync.Mutex
}
 
func Check(a *Account)  {
    time.Sleep(1 * time.Second)
}
 
func (a *Account)SetAccount(n int)  {
    a.money = n
}
 
func (a *Account)GetAccount() (n int) {
    return a.money
}
 
func (a *Account) buy1(n int)  {
    a.flag.Lock()
    if a.money > n {
        Check(a)
        a.money -= n
    }
    a.flag.Unlock()
    fmt.Println(a.money)
}
 
 
func (a *Account) buy2(n int)  {
    a.flag.Lock()
    if a.money > n {
        Check(a)
        a.money -= n
    }
    a.flag.Unlock()
    fmt.Println(a.money)
}
 
func main() {
    var test52_1 Account
    test52_1.SetAccount(10)
 
    go test52_1.buy1(5)
    go test52_1.buy2(6)
    for {
 
    }
}

12、wait

我們自己實(shí)現(xiàn)wait

package main
 
import "fmt"
//Add() 計(jì)數(shù)加1
//Done() 計(jì)數(shù)減1
//Wait() 主函數(shù)調(diào)用
func main() {
    test53_1 := make(chan int,2)
    count := 2
    go func() {
        fmt.Println("子協(xié)程1")
        test53_1 - 1
    }()
    go func() {
        fmt.Println("子協(xié)程2")
        test53_1 - 2
    }()
 
    for range test53_1 {
        count --
        if count == 0 {
            fmt.Println("所有的子協(xié)程都已經(jīng)結(jié)束")
            close(test53_1)
        }
    }
}

go語(yǔ)言為我們實(shí)現(xiàn)wait

package main
 
import (
    "fmt"
    "sync"
)
//Add() 計(jì)數(shù)加1
//Done() 計(jì)數(shù)減1
//Wait() 主函數(shù)調(diào)用
func main() {
 
    var wait_group sync.WaitGroup
 
    //這里就是子協(xié)程的個(gè)數(shù)
    wait_group.Add(2)
    //test54_1 := make(chan int,2)
 
    go func() {
        fmt.Println("子協(xié)程1")
        wait_group.Done()
    }()
    go func() {
        fmt.Println("子協(xié)程2")
        wait_group.Done()
    }()
 
 
    wait_group.Wait()
    //close(test53_1)
    fmt.Println("所有的子協(xié)程都結(jié)束")
 
}

以上就是詳解go語(yǔ)言的并發(fā)的詳細(xì)內(nèi)容,更多關(guān)于go語(yǔ)言的并發(fā)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!

您可能感興趣的文章:
  • 快速解決Golang Map 并發(fā)讀寫(xiě)安全的問(wèn)題
  • 淺談golang并發(fā)操作變量安全的問(wèn)題
  • golang高并發(fā)限流操作 ping / telnet
  • golang gin 框架 異步同步 goroutine 并發(fā)操作
  • Golang 實(shí)現(xiàn)分片讀取http超大文件流和并發(fā)控制
  • golang-gin-mgo高并發(fā)服務(wù)器搭建教程
  • 詳解Go多協(xié)程并發(fā)環(huán)境下的錯(cuò)誤處理
  • Django高并發(fā)負(fù)載均衡實(shí)現(xiàn)原理詳解
  • golang通過(guò)context控制并發(fā)的應(yīng)用場(chǎng)景實(shí)現(xiàn)
  • 一百行Golang代碼實(shí)現(xiàn)簡(jiǎn)單并發(fā)聊天室
  • 基于Django的樂(lè)觀鎖與悲觀鎖解決訂單并發(fā)問(wèn)題詳解

標(biāo)簽:儋州 物業(yè)服務(wù) 遼寧 電子產(chǎn)品 安康 西雙版納 青海 海南

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《詳解go語(yǔ)言的并發(fā)》,本文關(guān)鍵詞  詳解,語(yǔ)言,的,并發(fā),詳解,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問(wèn)題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無(wú)關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《詳解go語(yǔ)言的并發(fā)》相關(guān)的同類信息!
  • 本頁(yè)收集關(guān)于詳解go語(yǔ)言的并發(fā)的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章