V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
The Go Programming Language
http://golang.org/
Go Playground
Go Projects
Revel Web Framework
CarrieBauch
V2EX  ›  Go 编程语言

一段 Go 代码输出疑惑

  •  
  •   CarrieBauch · 308 天前 · 2241 次点击
    这是一个创建于 308 天前的主题,其中的信息可能已经有所发展或是发生改变。

    下面的代码中,为什么会输出 5,6,7,8,9 啊?难道不是应该输出 6,7,8,9 吗?

    package main
    
    import "log"
    
    func NewRingBuffer(inCh, outCh chan int) *ringBuffer {
    	return &ringBuffer{
    		inCh:  inCh,
    		outCh: outCh,
    	}
    }
    
    type ringBuffer struct {
    	inCh  chan int
    	outCh chan int
    }
    
    func (r *ringBuffer) Run() {
    	for v := range r.inCh {
    		select {
    		case r.outCh <- v:
    		default:
    			<-r.outCh // pop one item from outchan
    			r.outCh <- v
    		}
    	}
    	close(r.outCh)
    }
    
    func main() {
    	inCh := make(chan int)
    	outCh := make(chan int, 4)
    	rb := NewRingBuffer(inCh, outCh)
    	go rb.Run()
    
    	for i := 0; i < 10; i++ {
    		inCh <- i
    	}
    
    	close(inCh)
    
    	for res := range outCh {
    		fmt.Println(res)
    	}
    
    }
    
    
    
    13 条回复    2023-06-26 11:05:08 +08:00
    iBugOne
        1
    iBugOne  
       308 天前
    竞争问题,你在 close(inCh) 之后加上 time.Sleep(5*time.Millisecond) 就好了
    iyear
        2
    iyear  
       308 天前   ❤️ 2
    并非稳定 5,6,7,8,9 的,我跑了一下也有 6,7,8,9 出现。在 close(inCh) 下方 sleep 就稳定复现 6,7,8,9 了。


    for i := 0; i < 10; i++ {
    inCh <- i
    }
    这段代码结束时存在一种可能,Run 协程在 for v := range r.inCh 接收了 9 ,然后切换到 main 开始遍历 outCh(此时 9 并未开始入队),会把里面的 5 读出来,这时就会产生 5,6,7,8,9 。如果 sleep ,就会切到 Run 协程,则 5 就会被 9 顶掉,就 6,7,8,9 了。
    flyqie
        3
    flyqie  
       308 天前 via Android
    善用-race 参数能帮助你解决很多奇怪的问题。
    eastphoton
        4
    eastphoton  
       308 天前   ❤️ 1
    试了一下-race 参数检测不出这个问题,但是确实属于 race condition
    CarrieBauch
        5
    CarrieBauch  
    OP
       308 天前
    @iyear 有道理,多谢解答。race condition 真是防不胜防
    flyqie
        6
    flyqie  
       308 天前
    @eastphoton #3

    多谢指点,手机端发帖看到 race condition 就下意识发了。

    看来-race 参数也不能太过信任。
    vitoliu
        7
    vitoliu  
       308 天前
    最好是通过 context 关闭 channel ,不要直接 close
    yianing
        8
    yianing  
       308 天前
    @eastphoton channel 本来就是协程之间传递数据用的,哪里来的 race ?
    wuzhewuyou
        9
    wuzhewuyou  
       307 天前   ❤️ 1
    有点意思,for i := 0; i < 10; i++

    这里的 10 换成偶数基本能输出 5 个,换成奇数一般是 4 个
    eastphoton
        10
    eastphoton  
       307 天前   ❤️ 1
    @yianing 没有 data race 但是有 race condition ,这是两个相似但不同的概念。
    channel 确实本身是同步原语,单从并发使用 channel 这一行为本身没有问题,所以不应该看作 data race 也确实没有被 race detector 报告,
    但是仍然属于 race condition ,因为计算结果不确定而受协程调度顺序影响,不同的事件时序下会产生不同的结果(并不一定有害,也可能是良性的,看是否符合开发者意图)
    gogogo1203
        11
    gogogo1203  
       307 天前
    只是 goroutines 的执行顺序不是固定的, 我记得以前碰过类似的问题.
    leonshaw
        12
    leonshaw  
       307 天前
    内层没有 select default ,搞不好 main 先读空了就会死锁
    CarrieBauch
        13
    CarrieBauch  
    OP
       306 天前
    @eastphoton @iyear

    感谢两位大佬的回复。

    再次打扰一下。针对这类型的问题,有没有什么书籍或者文章系统性的介绍吗?想去查漏补缺一下,补齐知识的盲点
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   我们的愿景   ·   实用小工具   ·   882 人在线   最高记录 6543   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 23ms · UTC 21:28 · PVG 05:28 · LAX 14:28 · JFK 17:28
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.