课件及源代码地址

精选留言(8)

• 

  橙子

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

  作者回复: 继续看我的close和广播那一节，你就会有答案

  2019-04-01

  

   1
• 

  「ZY」

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

  作者回复: 主携程会阻塞等待接收10个ch传来的我数据。所以在循环退出前程序不会退出

  2019-03-26

  

   1
• 

  Geek_4c7e99

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

  作者回复: Before和After的一样吗？
  什么机器？
  

  2019-08-01

   1

  
• 

  Clany

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

  

  
• 

  manatee

  想请教下老师学习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-03

  

  
• 

  我不会算法

  老师, 我又去看了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-04-02

  

  
• 

  Alexdown

  1：45“aggregation（聚合，聚集）“

  2019-03-26

  

  