美文网首页
golang回顾 channel

golang回顾 channel

作者: wangrui927 | 来源:发表于2018-09-03 20:54 被阅读0次

    系统地回顾golang知识,今天总结一下channel的一些特点与一些简单实现。
    Don't communicate by sharing memory;share memory by communicating.

    1,通道类型本身就是并发安全的,这也是go自带唯一可以满足并发安全的类型。
    2,通道需要初始化,因为其是引用类型,否则其值为nil,对其的任何操作都会阻塞。
    3,可以理解为FIFO队列,即便被阻塞的对象也是按照严格顺序的,通道为空,a协程取数据,然后b协程取数据,两者都会阻塞,当通道有数据之后,仍然会遵循a与b的先后顺序。
    4,同一个通道的接收发送操作是互斥的,runtime同时只会执行一个通道的接收或者发送,不会同时进行。
    5,对于通道中的元素也是,如果它还未完成被复制进通道,那么其也绝不会被接收方所看到。
    6,进入通道的并不是元素本身,而是元素的副本,并且这个操作是不会被割裂的,也就是说副本进入了通道,但原对象未被删除。
    7,同上,取出数据的时候也不会出现读取后通道中的元素未被删除的情况。
    8,复制元素与将复制的副本放入通道之前,发送的操作会阻塞。
    9,通道的阻塞机制是为了实现操作的互斥和元素的完成。
    10,缓冲通道元素满,接收与发送都会阻塞,但恢复后接收与发送的顺序是绝对公平的,不会混乱。对于非缓冲通道,一开始就是阻塞的,生产者和消费者同时对接,阻塞才会解除。
    11,可以理解为非缓冲通道是同步传输,缓冲通道是异步传输。
    12,引发panic的情况:对关闭的通道进行操作;关闭已关闭的通道;
    13,元素在通道中传递是浅层拷贝。

    最好不要从通道的接收方关闭通道,而应从通道的发送方关闭通道

    package main
    
    import "fmt"
    
    func main() {
        chx := make(chan int, 2)
        // sender
        go func() {
            for i := 0; i < 10; i++ {
                fmt.Printf("Sender: sending element %v...\n", i)
                chx <- i
            }
            fmt.Println("Sender: close the channel...")
            close(chx)
        }()
    
        // receiver
        for {
            elem, ok := <-chx
            if !ok {
                fmt.Println("Receiver: closed channel")
                break
            }
            fmt.Printf("Receiver: received an element: %v\n", elem)
        }
    
        fmt.Println("End.")
    }
    

    14,单向通道,即 var uselessChan = make(chan<- int,1) 或 var uselessChan = make(<-chan int, 1),前者只能发,后者只能收。那么这样的单向通道的主要通途是约束其他代码的行为

    15,select只能与通道联用,select 有 候选分支与默认分支,即 case与default,每个case只能包含通道的操作,比如接收表达式。

    相关文章

      网友评论

          本文标题:golang回顾 channel

          本文链接:https://www.haomeiwen.com/subject/aewiwftx.html