一、goroutine

與傳統(tǒng)的系統(tǒng)級線程和進程相比，協(xié)程的大優(yōu)勢在于其“輕量級”，可以輕松創(chuàng)建上百萬個而不會導致系統(tǒng)資源衰竭，而線程和進程通常多也不能超過1萬個。這也是協(xié)程也叫輕量級線程的原因。
golang原生支持并發(fā)編程
輕量級線程
非搶占式多任務處理，由協(xié)程主動交出控制權
編譯器/解釋器/虛擬機層面的多任務
多個協(xié)程可能在一個或多個線程上運行

創(chuàng)新互聯(lián)公司是一家專業(yè)提供六盤水企業(yè)網站建設,專注與成都網站建設、網站制作、HTML5建站、小程序制作等業(yè)務。10年已為六盤水眾多企業(yè)、政府機構等服務。創(chuàng)新互聯(lián)專業(yè)網站設計公司優(yōu)惠進行中。

---

1.1 go對協(xié)程的實現(xiàn)

goroutine--Go對協(xié)程的實現(xiàn)
go + 函數(shù)名：啟動一個協(xié)程執(zhí)行函數(shù)體

package main

import (
    "fmt"
    "time"
)

func test_Routine() {
    fmt.Println("This is one routine!!!")
}

func Add(x, y int) {
    z := x + y
    fmt.Println(z)
}

func main() {
    for i := 1; i < 10; i++ {
        //啟動一個協(xié)程執(zhí)行函數(shù)體
        go Add(i, i)
    }

    //為避免并發(fā)執(zhí)行后程序立即退出，先sleep 2秒
    time.Sleep(2)
}

---

package main

import (
    "fmt"
    "runtime"
    "time"
)

func main() {
    //定義一個數(shù)組
    var a [10]int
    //循環(huán)并發(fā)執(zhí)行匿名函數(shù)，實現(xiàn)
    for i := 0; i < 10; i ++ {
        go func(i int) {
            for {
                a[i]++
                //主動讓go協(xié)程讓出時間片
                runtime.Gosched()
            }
        }(i)
    }
    time.Sleep(time.Millisecond)
    fmt.Println(a)
}

二、channel

Go語言在語言級別提供的goroutine間的通信方式
不要通過共享來通信，而要通過通信來共享。
channel的讀寫默認是阻塞的，除非有goroutine對其進行操作。

package main

import (
    "fmt"
    "strconv"
)

//定義一個加法函數(shù)，傳入x，y整型參數(shù)，quit整型通道
func Add(x, y int, quit chan int) {
    z := x + y
    fmt.Println(z)

    //發(fā)送 1 到channel quit
    quit <- 1
}

//讀取channel中的數(shù)據(jù)
func Read(ch chan int) {
    //將channel中數(shù)據(jù)發(fā)送出去，賦值給value
    value := <-ch

    fmt.Println("value:" + strconv.Itoa(value))
}

//寫數(shù)據(jù)到channel中
func Write(ch chan int) {
    //ch <- 10
}

func main() {
    //ch := make(chan int)
    //go Read(ch)
    //go Write(ch)

    //time.Sleep(10)

    //fmt.Println("end of code")

    //定義一個容量為10的非阻塞整型通道切片，變 量名為chs
    chs := make([]chan int, 10)
    //循環(huán)地給channel切片chs初始化
    for i := 0; i < 10; i++ {
        chs[i] = make(chan int)
        go Add(i, i, chs[i])
    }

    //遍歷channel切片chs,并從channel中發(fā)出數(shù)據(jù)，留空
    for _, v := range chs {
        <-v
    }
}

三、緩沖channel

定義: c = make(chan int, n) n為緩沖區(qū)的大小，代表channel可以存儲多少個元素，這幾個元素可以無阻塞的寫入，緩存的元素寫滿之后阻塞，除非有goroutine操作。

---

例子中定義一個容量為2的channel,

---

// 緩沖channel
package main

import (
    "fmt"
    "time"
)

// 定義一個chnnel類型變量 ch
var ch chan int

//測試buffered channel函數(shù)
func test_channel() {
    // 第一次發(fā)送常量1到channel ch
    ch <- 1
    fmt.Println("ch 1")
    // 第二次發(fā)送常量1到channel ch
    ch <- 1
    fmt.Println("ch 2")
    // 第三次發(fā)送常量1到channel ch
    ch <- 1
    fmt.Println("come to end goroutine 1")
}

func main() {
    ch = make(chan int, 0) // 等價于 ch = make(chan int) 都是不帶緩沖的channel
    ch = make(chan int, 2) // 是帶緩沖的channel
    go test_channel()
    time.Sleep(2 * time.Second)
    fmt.Println("running end!")
    <-ch

    time.Sleep(time.Second)
}

output:
ch 1
ch 2
running end!
come to end goroutine 1

---

package main

import "fmt"

func main() {
    c := make(chan int, 3   )//修改2為1就報錯，修改2為3可以正常運行
    c <- 1
    c <- 2
    fmt.Println(<-c)
    fmt.Println(<-c)
}

四、select

Linux很早就引入的函數(shù)，用來實現(xiàn)非阻塞的一種方式。Go語言直接在語言級別支持select關鍵字，用于處理異步IO 問題。我們上面介紹的都是只有一個channel的情況，那么如果存在多個channel的時候，我們該如何操作呢，Go里面提供了一個關鍵字select，通過select可以監(jiān)聽channel上的數(shù)據(jù)流動。
select默認是阻塞的，只有當監(jiān)聽的channel中有發(fā)送或接收可以進行時才會運行，當多個channel都準備好的時候，select是隨機的選擇一個執(zhí)行的。

package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)

    //匿名函數(shù)，傳入一個參數(shù)整型channel類型ch
    go func(ch chan int) {
        ch <- 1
    }(ch)

    time.Sleep(time.Second)

    select {
    //如果ch成功讀到數(shù)據(jù)，則執(zhí)行下面的語句
    case <-ch:
        fmt.Print("come to read ch!")
    default:
        fmt.Print("come to default!")
    }
}

---

// 實現(xiàn)超時控制
package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)
    //定義一個channel timeout
    timeout := make(chan int, 1)

    //定義一個匿名函數(shù)，用來實現(xiàn)超時控制
    go func() {
        time.Sleep( time.Second)
        timeout <- 1
    }()

    select {
    case <-ch:
        fmt.Print("come to read ch!\n")
    case <-timeout:
        fmt.Print("come to timeout!\n")
    }

    fmt.Print("end of code!")
}

---

// 使用time.After(time.Second)實現(xiàn)控制
package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)

    select {
    case <-ch:
        fmt.Print("come to read ch!\n")
    case <-time.After(time.Second):
        fmt.Print("come to timeout!\n")
    }

    fmt.Print("end of code!")
}

---

// goroutine_2.go
package main

import (
    "fmt"
    "runtime"
    "strconv"
    "time"
)

func main() {
    //協(xié)程1
    go func() {
        for i := 1; i < 100; i++ {
            if i == 10 {
                //主動出讓cpu 使用的話 需要 導入 runtime包
                runtime.Gosched()
            }
            fmt.Println("routine 1:" + strconv.Itoa(i))
        }
    }()

    //協(xié)程2
    go func() {
        for i := 100; i < 200; i++ {
            fmt.Println("routine 2:" + strconv.Itoa(i))
        }
    }()

    time.Sleep(time.Second)
}

網頁名稱：go語言并發(fā)編程
本文URL：http://www.rwnh.cn/article40/jscoeo.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供網站建設、App設計、面包屑導航、電子商務、云服務器、用戶體驗

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)