对于无缓冲的 channel,用 select 来处理通道超时时间,如果在接收超时后,退出接收,那么该通道的发送会被阻塞吗?

murphyzhao · 2019-10-11 09:00:51 · 1763 次点击 · 大约8小时之前 开始浏览    置顶
这是一个创建于 2019-10-11 09:00:51 的主题,其中的信息可能已经有所发展或是发生改变。

对于无缓冲的 channel,用 select 来处理通道超时时间,如果在接收超时后,退出接收,那么该通道的发送会被阻塞吗?

会阻塞吗?实现原理是什么? :smiley:

测试代码如下:

package main
import (
    "fmt"
    "time"
)
func main() {
    c1 := make(chan string)
    go func{
        time.Sleep(2 * time.Second)
        c1 <- "this is send"
        fmt.Println("send ok")
    }()

    select {
    case res := <- c1:
        fmt.Println(res)
    case <- time.After(1 * time.Second):
        fmt.Println("timeout")
    }
    time.Sleep(2 * time.Second)
    fmt.Println("over")
}

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

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

1763 次点击  
加入收藏 微博
6 回复  |  直到 2019-10-12 15:34:11
JYZ1024
JYZ1024 · #1 · 6年之前

对于无缓冲的channel,发送时会阻塞在发送位置直到被接收后程序继续往下执行,接收时会阻塞在接收位置直到接收到信息然后程序继续往下执行。是否阻塞和时间无关,是为了某种情景下认为的控制。就本例而言,“this is send"写入channel中,此时select模块已经执行完成,消息没有被接收,因此"send ok"直到程序结束也不会被输出。

murphyzhao
murphyzhao · #2 · 6年之前
JYZ1024JYZ1024 #1 回复

对于无缓冲的channel,发送时会阻塞在发送位置直到被接收后程序继续往下执行,接收时会阻塞在接收位置直到接收到信息然后程序继续往下执行。是否阻塞和时间无关,是为了某种情景下认为的控制。就本例而言,“this is send"写入channel中,此时select模块已经执行完成,消息没有被接收,因此"send ok"直到程序结束也不会被输出。

就本例而言,"send ok" 确实不会输出,但是 <- chan 是如何知道此时 recv 不存在(没有就绪)?

focusonline
focusonline · #3 · 6年之前

我觉得阻塞主要是对接收方来说的 通道是空的就是阻塞, 对发送方不存在这个问题

momaek
momaek · #4 · 6年之前
murphyzhaomurphyzhao #2 回复

#1楼 @JYZ1024 就本例而言,"send ok" 确实不会输出,但是 <- chan 是如何知道此时 recv 不存在(没有就绪)?

channel 的源码里面有两个 Goroutine 队列,一个是 接收队列,一个 发送队列。 对于无缓冲的 channel ,一个写操作过来了,会看先看看接收队列有没有 goroutine,如果有的话那么久直接写。如果接收队列没有 goroutine,那么把这个写操作的 goroutine 放到 发送队列。

murphyzhao
murphyzhao · #5 · 6年之前
momaekmomaek #4 回复

#2楼 @murphyzhao channel 的源码里面有两个 Goroutine 队列,一个是 接收队列,一个 发送队列。 对于无缓冲的 channel ,一个写操作过来了,会看先看看接收队列有没有 goroutine,如果有的话那么久直接写。如果接收队列没有 goroutine,那么把这个写操作的 goroutine 放到 发送队列。

:dart: 感谢!后面我看看源码,深入理解下

murphyzhao
murphyzhao · #6 · 6年之前
focusonlinefocusonline #3 回复

我觉得阻塞主要是对接收方来说的 通道是空的就是阻塞, 对发送方不存在这个问题

:grinning: send 和 recv 都会出现阻塞,有应用场景,在生产者消费者里,保证了每条消息的可达性

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