golang中的通道类型是一种特殊的类型, 类型名字为chan。在任何时候,同时只有一个goroutine访问通道进行并发和获取数据,goroutine间通过通道就可以进行通信。我们可以通过go关键字创建goroutine。
通道本身是同步的,通道的发送和接受数据默认是同步的,且遵循先进先出的规则以保证数据发送的顺序。
- 通道分为双向通道和单向通道。
- 双向通道:
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!!")
}
- 通道分无缓冲通道和缓冲通道
- 无缓冲通道
unbufferChan1 := make(chan int)
unbufferChan2 := make(chan int, 0)
- 缓冲通道
bufferChan := make(chan int, 1)
无缓冲通道的特点是,发送的数据需要被读取后,发送才会完成,它阻塞场景:
- 通道中无数据,但执行读通道。
- 通道中无数据,向通道写数据,但无协程读取。
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
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")
}
有疑问加站长微信联系(非本文作者)