课件及源代码地址

蔡老师您好： 您这节课的代码 有没有可能会出现 channel在取数的时候，上面的go协程还没跑完 ch里面还没有数据 for i:0;i<10;i++{ go func(){ ch<-ret } } total="" for i:0;i<10;i++{ total+=<-ch }

for 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 希望老师帮忙解答

从示例代码来看，与上一节相比，仅仅只是多了一个聚合操作，将所有协程的操作，ch <- ret，从 channel 中取出来，+= <-ch，然后再 return。 如果和 WaitGroup 的方式来比较的话，不知道各自有什么优劣？

想请教下老师学习go的话哪些书籍或者学习资料比较有用呢

老师 我按照这个代码发现每次打印出来每次开启的协程数目都不一致，是与我的硬件机器有关系吗

老师，我往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!

老师, 我又去看了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 golang的 CSP模型(独有)，goroutine + channel; 方案2 sync.WaitGroup, 和Java的 CountDonwLatch 类似。 补充方案2 sync.WaitGroup代码 func RunTask(i int) string { time.Sleep(time.Millisecond * 10) return fmt.Sprintf("return form %d", i) } func TestWaitAllResponseDone(t *testing.T) { numOfRunner := 10 var wg sync.WaitGroup strSlice := make([]string, numOfRunner) //这里 length 和 capacity 都是 10，接收返回值 for i := 0; i < numOfRunner; i++ { wg.Add(1) go func(i int) { strSlice[i] = RunTask(i) //通过i 保证每个协程修改的地方独立，thread-safe wg.Done() }(i) } wg.Wait() fmt.Println("all result:\n", strings.Join(strSlice, ",\n")) // 使用 12讲 strings的Join函数 fmt.Print(len(strSlice), cap(strSlice)) //验证 切片的长度和容量 }

// 实现所有任务返回且关闭channel func AllResponse() string { numOfRoutine := 10 ch := make(chan string, numOfRoutine) for i := 0; i < numOfRoutine; i++ { go func(i int) { ch <- fmt.Sprintf("The result is from %d", i) }(i) } totalResult := "" for i := 0; i < numOfRoutine; i++ { // 阻塞式获取channel中的所有消息 totalResult += <-ch + "\n" } // 关闭channel close(ch) return totalResult } func AllResponseWithRange() string { numOfRoutine := 10 var wg sync.WaitGroup ch := make(chan string, numOfRoutine) for i := 0; i < numOfRoutine; i++ { wg.Add(1) go func(i int) { ch <- fmt.Sprintf("The result is from %d", i) wg.Done() }(i) } wg.Wait() // 关闭channel close(ch) totalResult := "" for v := range ch{ totalResult += v + "\n" } return totalResult } func TestGetAllResponse(t *testing.T) { //t.Log(AllResponse()) t.Log(AllResponseWithRange()) }

@橙子 看了对象池这节中, 蓝士钦老哥的留言, 突然就明白该怎么写了. 老师说的去看 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()) }