golang协程——通道channel阻塞

  新的一年开始了,无论今天之前发生了什么,向前看,就够了。golang

  说到channel,就必定要说一说线程了。任何实际项目,不管大小,并发是必然存在的。并发的存在,就涉及到线程通讯。在当下的开发语言中,线程通信主要有两种,共享内存与消息传递。共享内存必定都很熟悉,经过共同操做同一对象,实现线程间通信。消息传递即经过相似聊天的方式。golang对并发的处理采用了协程的技术。golang的goroutine就是协程的实现。协程的概念很早就有,简单的理解为轻量级线程,goroutine就是为了解决并发任务间的通讯而设计的。golang解决通讯的理念是:不要经过共享内存来通讯,而应该经过通讯来共享内存。golang解决方案是消息传递机制,消息的传递就是经过channel来实现的。并发

  channel的使用很简单,这里就不在粘别人的东西了。如今谈一谈对channe阻塞l的理解。  函数

  发送者角度:对于同一个通道,发送操做(协程或者函数中的),在接收者准备好以前是阻塞的。若是chan中的数据无人接收,就没法再给通道传入其余数据。由于新的输入没法在通道非空的状况下传入。因此发送操做会等待 chan 再次变为可用状态:就是通道值被接收时(能够传入变量)。spa

  接收者角度:对于同一个通道,接收操做是阻塞的(协程或函数中的),直到发送者可用:若是通道中没有数据,接收者就阻塞了。线程

  经过一个简单的例子来讲明:设计

  

 1 package main
 2 
 3 import (
 4     "fmt"
 5 )
 6 
 7 func f1(in chan int) {
 8     fmt.Println(<-in)
 9 }
10 
11 func main() {
12     out := make(chan int)
13     out <- 2
14     go f1(out)
15 }

  运行结果:fatal error: all goroutines are asleep - deadlock!code

  这是因为第13行以前不存在对out的接收,因此,对于out <- 2来讲,永远是阻塞的,即一直会等下去。协程

  将13,14行互换对象

 1 package main
 2 
 3 import (
 4     "fmt"
 5 )
 6 
 7 func f1(in chan int) {
 8     fmt.Println(<-in)
 9 }
10 
11 func main() {
12     out := make(chan int)
13     go f1(out)
14     out <- 2
15 }

  运行结果:2blog

  14行前存在对管道的读操做,因此out <- 2 是合法的。就像前文说的,发送操做在接收者准备好以前是阻塞的。

相关文章
相关标签/搜索