为什么在 select 语句中向另一个无缓冲 channel 写入数据会造成阻塞

gaffey · 2020-09-21 15:32:55 · 1233 次点击 · 大约8小时之前 开始浏览    置顶
这是一个创建于 2020-09-21 15:32:55 的主题,其中的信息可能已经有所发展或是发生改变。

package main

import (
    "fmt"
    "time"
)

func main() {
    ch1 := make(chan int)
    ch2 := make(chan int)

    go func() {
        for {
            select {
            case v := <-ch1:
                fmt.Println("ch1: ", v)
                ch2 <- v            // 到这里阻塞了
                fmt.Println("send to ch2")
            case v := <-ch2:
                fmt.Println("ch2: ", v)
            }
        }
    }()

    ch1 <- 1
    for {
        time.Sleep(1 * time.Second)
    }
}

程序输出

ch1:  1

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

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1233 次点击  
加入收藏 微博
5 回复  |  直到 2020-10-07 10:28:21
yykpf
yykpf · #1 · 5年之前

我的理解是因为你是在 一个协程中对同一个 channel进行的读写操作,会等待

hacky
hacky · #2 · 5年之前

向无缓存的chan发送数据,这个携程就被一直阻塞了,后一个case无法执行,因为这个携程处于阻塞态。而如果,你在外面接收ch2的数据,就会释放阻塞态。

...
    ch1 <- 1
    t := <-ch2
    fmt.Println("ch2: --", t)
    for {
        time.Sleep(1 * time.Second)
    }
...

输出结果:

ch1:  1
ch2: -- 1
send to ch2

而如果你想要实现你想要的结果,则只需要将给ch2发送数据,包含到另一个携程中:

package main

import (
    "fmt"
    "time"
)

func main() {
    ch1 := make(chan int)
    ch2 := make(chan int)

    go func() {
        for {
            select {
            case v := <-ch1:
                fmt.Println("ch1: ", v)
                go func(v int) {
                    ch2 <- v            // 这里阻塞子携程
                    fmt.Println("send to ch2")
                }(v)
            case v := <-ch2:  // 父携程等待获取
                fmt.Println("ch2: ", v)
            }
        }
    }()

    ch1 <- 1
    for {
        time.Sleep(1 * time.Second)
    }
}
gaffey
gaffey · #3 · 5年之前
hackyhacky #2 回复

向无缓存的chan发送数据,这个携程就被一直阻塞了,后一个case无法执行,因为这个携程处于阻塞态。而如果,你在外面接收`ch2`的数据,就会释放阻塞态。 ``` ... ch1 <- 1 t := <-ch2 fmt.Println("ch2: --", t) for { time.Sleep(1 * time.Second) } ... ``` 输出结果: ``` ch1: 1 ch2: -- 1 send to ch2 ``` 而如果你想要实现你想要的结果,则只需要将给`ch2`发送数据,包含到另一个携程中: ``` package main import ( "fmt" "time" ) func main() { ch1 := make(chan int) ch2 := make(chan int) go func() { for { select { case v := <-ch1: fmt.Println("ch1: ", v) go func(v int) { ch2 <- v // 这里阻塞子携程 fmt.Println("send to ch2") }(v) case v := <-ch2: // 父携程等待获取 fmt.Println("ch2: ", v) } } }() ch1 <- 1 for { time.Sleep(1 * time.Second) } } ```

非常感谢

gaffey
gaffey · #4 · 5年之前
yykpfyykpf #1 回复

我的理解是因为你是在 一个协程中对同一个 channel进行的读写操作,会等待

是的, 看了其他答案的例子理解了, 要用新的协程处理

daiyudong
daiyudong · #5 · 5年之前

无缓冲区的通道读和写要同时准备好才行,而且读要先准备好,如果写到通道里读没有准备好后就会发生堵塞。

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