如果直接在main方法中读取会出现error,如果使用go receive方式程序正常

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

 read chan by for range  in main-thread.png


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

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

989 次点击  
加入收藏 微博
12 回复  |  直到 2019-02-20 21:30:22
waini1110
waini1110 · #1 · 6年之前

因为如果放在main中,会从channel中读数据,没有读到就会死锁。

does
does · #2 · 6年之前

@waini1110</a>

首先感谢回答,另外:

对于读取来说应该是发现channel有数据就拿 ,没有数据就阻塞
对于发送来说向channel中存,存完阻塞,等待channel数据被取走后再存
现在我在main中不断读取channel, 假设channel不存在数据,他应该只是阻塞状态,为什么会提示 all goroutines are asleep - deadlock
didadi
didadi · #3 · 6年之前

因为你只写了五个,五个写完之后,只有读的操作,没有写的操作,才会死锁。你写完之后关掉channel,就不会有这个问题

didadi
didadi · #4 · 6年之前
didadididadi #3 回复

因为你只写了五个,五个写完之后,只有读的操作,没有写的操作,才会死锁。你写完之后关掉channel,就不会有这个问题

抱歉,是十个

didadi
didadi · #5 · 6年之前
didadididadi #4 回复

#3楼 @didadi 抱歉,是十个

o,还得注意,关闭channel 的操作不能和读取channel 的操作在一个协程里

shenwei12303
shenwei12303 · #6 · 6年之前

这个代码一共创建了11个goroutine, send 10个, main 1个, 当send 10 个都运行完后, 唯一一个main goroutine就阻塞在接受通道的for循环那等待数据进来, 此时没有任何goroutine可以运行, 所以发生死锁

does
does · #7 · 6年之前
didadididadi #5 回复

#4楼 @didadi o,还得注意,关闭channel 的操作不能和读取channel 的操作在一个协程里

多谢回答,现在明白些了, 另外我问一下, 1.range方式读取chan , 如果不手动close掉chan ,对于range来说,他会一直读取chan是吗? 我尝试过读取 ` ch := make(chan int)

for n:= range ch{ fmt.Println(n) } `
这样是会报错的。

  1. 我能简单的把go协程理解成线程安全的队列吗?
didadi
didadi · #8 · 6年之前
doesdoes #7 回复

#5楼 @didadi 多谢回答,现在明白些了, 另外我问一下, 1.range方式读取chan , 如果不手动close掉chan ,对于range来说,他会一直读取chan是吗? 我尝试过读取 ` ch := make(chan int) for n:= range ch{ fmt.Println(n) } ` 这样是会报错的。 2. 我能简单的把go协程理解成线程安全的队列吗?

这两个不是一个问题,第一:for range 去读取channel 是一直去读取的,直到你的channel 关闭。这是正常情况。第二: ch := make(chan int) for n:= range ch{ fmt.Println(n) }这种,创建并没有写入channel ,所以读取的时候,会直接报错deadlock。

does
does · #9 · 6年之前
didadididadi #8 回复

#7楼 @does 这两个不是一个问题,第一:for range 去读取channel 是一直去读取的,直到你的channel 关闭。这是正常情况。第二: ` ch := make(chan int) for n:= range ch{ fmt.Println(n) } `这种,创建并没有写入channel ,所以读取的时候,会直接报错deadlock。

明白了,多谢回答

does
does · #10 · 6年之前
shenwei12303shenwei12303 #6 回复

这个代码一共创建了11个goroutine, send 10个, main 1个, 当send 10 个都运行完后, 唯一一个main goroutine就阻塞在接受通道的for循环那等待数据进来, 此时没有任何goroutine可以运行, 所以发生死锁

多谢回答,你这思路真好。

northbright
northbright · #11 · 6年之前
  • @didadi 正解
  • for-range的loop只有在channel被关闭后才会退出。所以会block你的main goroutine,造成Dead Lock。
  • 如果你使用如下code,就不会Dead Lock(即使没有关闭channel):
package main

import "fmt"

func main() {
    ch := make(chan int, 1)

    for i := 0; i < 10; i++ {
        go Send(ch, i)
    }

    for i := 0; i < 10; i++ {
        fmt.Printf("i: %v\n", <-ch)
    }
}

func Send(ch chan int, number int) {
    ch <- number
}
does
does · #12 · 6年之前
northbrightnorthbright #11 回复

* @didadi 正解 * for-range的loop只有在channel被关闭后才会退出。所以会block你的main goroutine,造成Dead Lock。 * 如果你使用如下code,就不会Dead Lock(即使没有关闭channel): ``` package main import "fmt" func main() { ch := make(chan int, 1) for i := 0; i < 10; i++ { go Send(ch, i) } for i := 0; i < 10; i++ { fmt.Printf("i: %v\n", <-ch) } } func Send(ch chan int, number int) { ch <- number } ``` * [for range loop on a Channel will Never Exit until it is Closed](https://github.com/northbright/Notes/blob/master/Golang/concurrency/for-range-loop-on-a-channel-will-never-exit-until-it-is-closed.md)

  • 多谢回答,现在已经搞懂了,最开始没有明白 for range 跟channel组合玩法。
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传