关于select多路复用的问题

MrDoubleU · 2018-06-23 10:05:45 · 1229 次点击 · 大约8小时之前 开始浏览    置顶
这是一个创建于 2018-06-23 10:05:45 的主题,其中的信息可能已经有所发展或是发生改变。

package main
import "fmt"
func main() {
    ch := make(chan int)
    for i := 0; i < 10; i++ {
        select {
        case  x:=<-ch:
            fmt.Println(x) 
        case ch <- i:
            fmt.Println(i)
        }
    }
}
  • 请问这段代码,为什么运行不了呢?无缓冲的channel遇到select会发生什么?

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

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

1229 次点击  
加入收藏 微博
9 回复  |  直到 2018-06-25 18:07:32
mlzhou
mlzhou · #1 · 7年之前

for循环只跑一下就被阻塞了,还能发生什么,case ch<-i

hellogophp
hellogophp · #2 · 7年之前

没有向通道写入数据

mortemnh
mortemnh · #3 · 7年之前

无缓冲select是同步(也就是不论是写入还是停止都会在同步下完成,不会先完成写入再完成读取),简单来说你这个就是死锁了

marlonche
marlonche · #4 · 7年之前

同一个channel出现在一个select的多个分支似乎没有实际用处

Donng
Donng · #5 · 7年之前

@mortemnh 说的是对的,ch 是无缓冲 channel,执行到 ch <- i 之后,如果没有接收方取值就会一直阻塞在这里,无法进入下次 for 循环。

birdkiller
birdkiller · #6 · 7年之前

你的代码和正常编译执行之间只差了一个default:

birdkiller
birdkiller · #7 · 7年之前

select本身就是找到第一个不阻塞的chan,如果都阻塞,就会执行default

Donng
Donng · #8 · 7年之前

@birdkiller default 可以编译通过但是程序上看其实没有意义,循环会一直走 default 分支。为 channel 加一个缓存,就解决了。

你会发现结果是 0, 2, 4 ... 因为 for 循环 i = 1 时执行的是 received,所以每次发送 i 都是间隔一次循环。

package main

import "fmt"

func main() {
    ch := make(chan int, 1)
    for i := 0; i < 10; i++ {
        select {
        case x := <-ch:
            fmt.Println("received", x)
        case ch <- i:
            fmt.Println("send", i)
        default:
            fmt.Println("阻塞了", i)
        }
    }
}
birdkiller
birdkiller · #9 · 7年之前

@Donng 你这一说我才看出来,原来这代码是有意义的。

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