Golang:无缓冲和单向channel

前端之家收集整理的这篇文章主要介绍了Golang:无缓冲和单向channel前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

简介

初学golang很容易混淆无缓冲的chan和只有一个元素的chan,认为这两个是一回事,其实是完全不同的,make(chan int) 是同步的,只能同时读写,没有读写会一直阻塞;make(chan int,1)是异步的,第一个入队的不会阻塞

c1:=make(chan int)        无缓冲
c2:=make(chan int,1)      有缓冲

code

package main

import (
    "fmt"
    "sync"
)

var wt sync.WaitGroup

func OutChan(noBufChan <-chan int) {

    //chan关闭后for退出循环,否则会死循环
    for v := range noBufChan {
        fmt.Println(v)
    }

    wt.Done()
}

func InChan(noBufChan chan<- int) {

    for i := 0; i < 5; i++ {
        noBufChan <- i
    }
    //v := <-noBufChan //invalid operation: <-noBufChan (receive from send-only type chan<- int)
    close(noBufChan)
    wt.Done()
}

func main() {

    wt.Add(2)

    //无缓冲的chan,同步方式,有读才能写入
    var noBufChan = make(chan int)

    go InChan(noBufChan)
    go OutChan(noBufChan)

    wt.Wait()

    fmt.Println("goroute全部退出")
}

猜你在找的Go相关文章