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全部退出")
}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!