关于golang:go系列5golang中的通道

5次阅读

共计 1367 个字符,预计需要花费 4 分钟才能阅读完成。

golang 中的通道类型是一种非凡的类型,类型名字为 chan。在任何时候,同时只有一个 goroutine 拜访通道进行并发和获取数据,goroutine 间通过通道就能够进行通信。咱们能够通过 go 关键字创立 goroutine。
通道自身是同步的,通道的发送和承受数据默认是同步的,且遵循先进先出的规定以保证数据发送的程序。

  1. 通道分为双向通道和单向通道。
  • 双向通道:
chan1 := make(chan int, 10)
  • 单向通道:
# 单向只写通道,10 示意通道的容量
chan2 := make(chan <- int, 10)
#单向只读通道,10 示意通道的容量
chan3 := make(<- chan int, 10)
package main

import (
    "time"

    "github.com/golang/glog"
)

func read(readChan <-chan int) {
    for data := range readChan {glog.Info(data)
    }
}

func write(writeChan chan<- int) {
    for i := 0; i < 100; i++ {
        writeChan <- i
        glog.Infof("write: %s", i)
    }
}

func main() {
    // 双向通道
    writeReadChan := make(chan int)
    // 传入双向通道主动会转换成一个单项通道
    go write(writeReadChan)
    glog.Info("start to read data from channel!")
    // 传入双向通道会主动转换成一个单项通道 `
    go read(writeReadChan)
    // 敞开 chan
    close(writeReadChan)
    time.Sleep(time.Second * 100)
    glog.Info("finishedAll!!")

}
  1. 通道分无缓冲通道和缓冲通道
  • 无缓冲通道
unbufferChan1 := make(chan int)
unbufferChan2 := make(chan int, 0)
  • 缓冲通道
bufferChan := make(chan int, 1)
  • 无缓冲通道的特点是,发送的数据须要被读取后,发送才会实现,它阻塞场景:

    1. 通道中无数据,但执行读通道。
    2. 通道中无数据,向通道写数据,但无协程读取。
func occasion1() {noBufChan := make(chan int)
    <-noBufChan
    fmt.Println("read")
}

// 场景 2
func occasion2() {ch := make(chan int)
    ch <- 1
    fmt.Println("write success no block")
}
  • 有缓存通道的特点是,有缓存时能够向通道中写入数据后间接返回,缓存中有数据时能够从通道中读到数据间接返回,这时有缓存通道是不会阻塞的,它阻塞场景是:

    1. 通道的缓存无数据,但执行读通道。
    2. 通道的缓存曾经占满,向通道写数据,但无协程读。
// 场景 1
func occasion1() {bufCh := make(chan int, 2)
    <-bufCh
    fmt.Println("read from no buffer channel success")
}

// 场景 2
func occasion2() {ch := make(chan int, 2)
    ch <- 1
    ch <- 2
    ch <- 3
    fmt.Println("write success no block")
}
正文完
 0