2019-04-01for i:=1;i<=10;i++{
go func(){
ch<-ret
}
}
for i:=1;i<=10;i++{
<-ch
}
老师 针对以上程序我有个疑问，怎样可以使用 for range 而不用以上的 for 递增循环，因为看到网上 有for range 遍历 channel
for v:=range ch {
fmt.Println(v)
}
其实我想问的是 这种情况下 在哪里close后 再进行for range 希望老师帮忙解答展开作者回复: 继续看我的close和广播那一节，你就会有答案
1
2019-03-26蔡老师您好：
您这节课的代码 有没有可能会出现
channel在取数的时候，上面的go协程还没跑完 ch里面还没有数据
for i:0;i<10;i++{
go func(){
ch<-ret
}
}
total=""
for i:0;i<10;i++{
total+=<-ch
}展开作者回复: 主携程会阻塞等待接收10个ch传来的我数据。所以在循环退出前程序不会退出
1
2019-08-01老师 我按照这个代码发现每次打印出来每次开启的协程数目都不一致，是与我的硬件机器有关系吗作者回复: Before和After的一样吗？
什么机器？ 1
2019-04-08老师，我往channel里面放的生产的数量，比如初始化i:=5，然后消费哪里还是j:=0，生产的不够消费就会阻塞，出现死锁情况。channel信道的输入输出一般是 成对 出现的，如果不成对那边就会出现死锁的情况。但是我如果反过来，生产大于消费，它不会阻塞，这种情况怎么理解呢？
func AllResponse() string {
numOfRunner := 10
ch := make(chan string, numOfRunner)
for i := 5; i < numOfRunner; i++ {
go func(i int) {
ret := runTask(i)
ch <- ret
}(i)
}
finalRet := ""
for j := 0; j < numOfRunner; j++ {
finalRet += <-ch + "\n"
}
return finalRet
}
报错：fatal error: all goroutines are asleep - deadlock!展开作者回复: 当你的buffered chan满的时候生产者放不进东西一样阻塞，但是你要注意你的接受者是主协程，而你的生产者是其他协程，所以不管生产者协程是否被阻塞，主要外部主协程退出，就会整合都推出了
2019-04-03想请教下老师学习go的话哪些书籍或者学习资料比较有用呢作者回复: 最有用的就是那本经典“Go programming”和Go的官方文档了。另外，youtube上有不少Go创始人的视频讲座都值得看看。
2019-04-03@橙子 看了对象池这节中, 蓝士钦老哥的留言, 突然就明白该怎么写了. 老师说的去看 27 | channel的关闭和广播 这节也是有涉及这些内容, 只是一下子没找到重点(或者说关键点)在哪儿, 看完之后, 还是很懵, 一头雾水. 代码如下:
var wg sync.WaitGroup
func AllResponse() string {
numOfRunner := 10
ch := make(chan string, numOfRunner)
for i := 0; i < 10; i++ {
wg.Add(1)
go func(i int) {
ch <- runTask(i)
wg.Done()
}(i)
}
finalStr := ""
// for i := 0; i < numOfRunner; i++ {
// finalStr += <-ch + "\n"
// }
go func() {
for {
if v, ok := <-ch; ok {
finalStr += v + "\n"
} else {
break
}
}
}()
wg.Wait()
return finalStr
}
func TestAllResponse(t *testing.T) {
fmt.Print(AllResponse())
}展开- 2019-04-02老师, 我又去看了close和广播的那节课, 然后改了下代码, 但是这个并不是安全的, 偶尔会有致命错误(fatal error: all goroutines are asleep - deadlock!), 希望老师能够指点一下, 是哪里需要调整, 谢谢您了! 麻烦您指点一下
var wg sync.WaitGroup
func AllResponse() string {
numOfRunner := 10
ch := make(chan string, numOfRunner)
for i := 0; i < 10; i++ {
go func(i int) {
wg.Add(1)
ch <- runTask(i)
}(i)
}
finalStr := ""
// for i := 0; i < numOfRunner; i++ {
// finalStr += <-ch + "\n"
// }
go func() {
for {
if v, ok := <-ch; ok {
fmt.Println(v, ok)
finalStr += v + "\n"
} else {
break
}
}
wg.Done()
}()
wg.Wait()
return finalStr
}
func TestAllResponse(t *testing.T) {
fmt.Print(AllResponse())
time.Sleep(time.Second)
}展开作者回复: 1. 你的wg.Add(1)要放在子线程的外面。你可以再仔细看看课程里的代码。
2. 实际上你没有必要用wait group，利用chan的阻塞就不会推出，只有channel关闭时才会break循环
3. 代码里没看见close啊 
2019-03-261：45“aggregation（聚合，聚集）“