系统地回顾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只能包含通道的操作,比如接收表达式。