golang回顾 channel

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

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

• 请尽量让自己的回复能够对别人有帮助
• 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
• 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
• 图片支持拖拽、截图粘贴等方式上传