Go缓冲channel和非缓冲channel的区别说明

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战，手把手教大家学习《Go缓冲channel和非缓冲channel的区别说明》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

在看本篇文章前我们需要了解阻塞的概念

在执行过程中暂停，以等待某个条件的触发 ，我们就称之为阻塞

在Go中我们make一个channel有两种方式，分别是有缓冲的和没缓冲的

缓冲channel 即 buffer channel 创建方式为 make(chan TYPE,SIZE)

如 make(chan int,3) 就是创建一个int类型，缓冲大小为3的 channel

非缓冲channel 即 unbuffer channel 创建方式为 make(chan TYPE)

如 make(chan int) 就是创建一个int类型的非缓冲channel

非缓冲channel 和 缓冲channel 的区别

非缓冲 channel，channel 发送和接收动作是同时发生的

例如 ch := make(chan int) ，如果没 goroutine 读取接收者

缓冲 channel 类似一个队列，只有队列满了才可能发送阻塞

代码演示

非缓冲 channel

package main
import (
 "fmt"
 "time"
)
func loop(ch chan int) {
 for {
  select {
  case i := 

<p>这里会报错 fatal error: all goroutines are asleep - deadlock! 就是因为 ch
</p><p>但如果我们把 ch 
</p><h3>缓冲 channel</h3>
<p>的阻塞只会发生在 channel 的缓冲使用完的情况下</p>

<pre class="brush:plain;">
package main
import (
 "fmt"
 "time"
)
func loop(ch chan int) {
 for {
  select {
  case i := 

<p>这里也会报 fatal error: all goroutines are asleep - deadlock! ，这是因为 channel 的大小为 3 ，而我们要往里面塞 4 个数据，所以就会阻塞住</p>
<p><strong>解决的办法有两个</strong></p>
<p>把 channel 开大一点，这是最简单的方法，也是最暴力的</p>
<p>把 channel 的信息发送者 ch 
</p><p><strong>补充：3种优雅的Go channel用法</strong></p>
<p>写Go的人应该都听过Rob Pike的这句话</p>
<blockquote>
<p>Do not communicate by sharing memory; instead, share memory by communicating.</p>
</blockquote>
<p>相信很多朋友和我一样，在实际应用中总感觉不到好处，为了用channel而用。但以我的切身体会来说，这是写代码时碰到的场景不复杂、对channel不熟悉导致的，所以希望这篇文章能给大家带来点新思路，对Golang优雅的channel有更深的认识 ：）</p>
<h2>Fan In/Out</h2>
<p>数据的输出有时候需要做扇出／入（Fan In／Out），但是在函数中调用常常得修改接口，而且上下游对于数据的依赖程度非常高，所以一般使用通过channel进行Fan In／Out，这样就可以轻易实现类似于shell里的管道。</p>

<pre class="brush:plain;">
func fanIn(input1, input2 

<h2>同步Goroutine</h2>
<p>两个goroutine之间同步状态，例如A goroutine需要让B goroutine退出，一般做法如下：</p>

<pre class="brush:plain;">
func main() {
   g = make(chan int)
   quit = make(chan bool)
   go B()
   for i := 0; i 

<p>可是了main函数没办法等待B合适地退出，所以B quit 没办法打印，程序直接退出了。</p>
<p>然而，chan是Go里的第一对象，所以可以把chan传入chan中，所以上面的代码可以把quit 定义为chan chan bool，以此控制两个goroutine的同步</p>

<pre class="brush:plain;">
func main() {
   g = make(chan int)
   quit = make(chan chan bool)
   go B()
   for i := 0; i 

<h2>分布式递归调用</h2>
<p>在现实生活中，如果你要找美国总统聊天，你会怎么做？</p>
<p>第一步打电话给在美国的朋友，然后他们也会发动自己的关系网，再找可能认识美国总统的人，以此类推，直到找到为止。</p>
<p>这在Kadmelia分布式系统中也是一样的，如果需要获取目标ID信息，那么就不停地查询，被查询节点就算没有相关信息，也会返回它觉得最近节点，直到找到ID或者等待超时。</p>
<p>好了，这个要用Go来实现怎么做呢？</p>

<pre class="brush:plain;">
func recursiveCall(ctx context.Context, id []byte, initialNodes []*node){
	seen := map[string]*node{} //已见过的节点记录
	request := make(chan *node, 3) //设置请求节点channel
        // 输入初始节点
	go func() {
		for _, n := range initialNodes {
			request 

<p>这时的buffered channel类似于一个局部queue，对需要的节点进行处理，但这段代码的精妙之处在于，这里的block操作是select的，随时可以取消，而不是要等待或者对queue的长度有认识。</p>
<p>以上为个人经验，希望能给大家一个参考，也希望大家多多支持golang学习网。如有错误或未考虑完全的地方，望不吝赐教。</p><p>文中关于golang的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《Go缓冲channel和非缓冲channel的区别说明》文章吧，也可关注golang学习网公众号了解相关技术文章。</p>