golang回顾 channel

wangrui927 · · 1465 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

系统地回顾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.")
}

有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:wangrui927

查看原文:golang回顾 channel

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1465 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传