GoLang 对Channel的理解

1 解释上回学习的谜团

# src/main/blocking3.go
package main

import (
    "fmt"
)

func f1(in chan int) {
    number := <- in
    fmt.Println(number)
}

func main() {
    out := make(chan int)
    out <- 2
    go f1(out)
    fmt.Println("end")
}

go run blocking3.go

fatal error: all goroutines are asleep - deadlock!
goroutine 1 [chan send]:
main.main()

只需要把 go f1(out)out <-2 对换一下就可以了

# src/main/blocking3.go
package main

import (
    "fmt"
)

func f1(in chan int) {
    number := <- in
    fmt.Println(number)
}

func main() {
    out := make(chan int)
    go f1(out)
    out <- 2    
    fmt.Println("end")
}

编译运行

2
end

???? 究竟为什么

GO的channel具有两个特点

  • 发送方。对于同一个通道,发送操作(协程或者函数中的),在接收者准备好之前是阻塞的;如果ch中的数据无人接收,就无法再给通道传入其他数据**;新的输入无法在通道非空的情况下传入。所以发送操作会等待 channel 再次变为可用状态:就是通道值被接收时(可以传入变量)。

  • 接收方。对于同一个通道,接收操作是阻塞的(协程或函数中的),直到发送者可用:如果通道中没有数据,接收者就阻塞了。

因此可以针对上述现象解释

 1) 第一种情况
 会造成死锁
   out <- 2  # 接受者阻塞,因为没有发送者(此时f1还没启动)
   go f1(out) 在f1中,通道 in 没有传送,所以一直等待;

 2) 不会造成死锁
   go f1(out)
   out <- 2
  f1在等待传送, main相当于一个协程(因为利用了out),等待out传送才关闭;
也因为如此f1的打印才得以输出

换一个方式看

package main

import (
    "fmt"
    "time"
)

func f1(in chan int) {
    fmt.Println( <- in)
    time.Sleep(1e9)
    fmt.Println('delay')
}

func main() {
    out := make(chan int)
    go f1(out)
    out <- 2
    fmt.Println("end")
}

输出

 2
end

可见f1 的delay已经来不及输出了,因为main协程已经结束了。

总结
channel:
从动态来看: channel是一种消息传递的承载体
从静态来看:是一种锁(无法传递时,所在的协程无法向下运行)

延伸:
信号量
生产者、消费者

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容