11 | 通道的高级玩法

精选留言(36)

• 
  江山如画

  2018-09-05

   20

  感觉方法应该挺多，就看解决的是不是优雅
  
  第一个问题：发现某个channel被关闭后，为了防止再次进入这个分支，可以把这个channel重新赋值成为一个长度为0的非缓冲通道，这样这个case就一直被阻塞了：
  for {
          select {
          case _, ok := <-ch1:
              if !ok {
                  ch1 = make(chan int)
              }
          case ..... :
              ////
          default:
              ////    
          }
      }
  
  第二个问题：可以用 break和标签配合使用，直接break出指定的循环体，或者goto语句直接跳转到指定标签执行
  
  break配合标签：
  
  ch1 := make(chan int, 1)
      time.AfterFunc(time.Second, func() { close(ch1) })
  loop:
      for {
          select {
          case _, ok := <-ch1:
              if !ok {
                  break loop
              }
              fmt.Println("ch1")
          }
      }
      fmt.Println("END")
  
  goto配合标签：
  
  ch1 := make(chan int, 1)
      time.AfterFunc(time.Second, func() { close(ch1) })
      for {
          select {
          case _, ok := <-ch1:
              if !ok {
                  goto loop
              }
              fmt.Println("ch1")
          }
      }
  loop:
      fmt.Println("END")

  展开
• 
  任性😀

  2018-09-25

   12

  demo24里边少了rand.Seed(time.Now().Unix())，不然每次随机数都是固定的顺序
• 
  笨笨

  2018-09-05

   7

  谢谢赫老师今日分享，回答问题如下
  1.对于select中被close的channel判断其第二个boolean参数，如果是false则被关闭，那么赋值此channel为nil，那么每次到这个nil的channel就会阻塞，select会忽略阻塞的通道，如果再搭配上default就一定能保证不会被阻塞了。
  2.通过定义标签，配合goto或者break能实现在同一个函数内任意跳转，故可以跳出多层嵌套的循环。

  展开

  作者回复: 你的问题是什么？

• 
  癫狂的小兵

  2018-09-05

   4

  请问当select语句发现多个分支满足条件时随机选择一个分支执行 那怎样让其他满足条件的分支执行呢？ for 循环 等待下一次循环时再执行？

  展开

  作者回复: 放在for循环里每次也是随机的，不过可以用for循环，或者再次执行select语句。

• 
  zhaopan

  2019-02-19

   3

  老师好:
  仅当select语句中的所有case表达式都被求值完毕后，它才会开始选择候选分支。
  当接收通道操作有多个满足条件时, 这里的所有case表达式都被求值完毕, 应该怎么理解?
  是多个case表达式都能接收到通道的数据么?
  如果都接收了, 随机选择一个分支去处理接收的通道数据. 那其他满足条件的case分支怎么执行到了?
  如果是外层加for循环, 重新select语句, 那上一次select的操作其他满足条件未被选择的case还能收到上一次的数据么?
  这里的原理是什么呢?
  

  展开

  作者回复: 这里只会检查一下接收操作或发送操作是否可以进行（是否不会被阻塞）。有兴趣的话可以看一下 runtime/select.go 中的 selectgo 函数的源码。

• 
  啵啵

  2018-09-11

   3

  第一个问题，如果判断到chan关闭，即取到的第二个值为false。则将该chan赋值为nil。
  第二个问题，根据情况使用goto或者return。或者加一个是否结束的标识，goto然后用两个break。
• 
  Kennedy

  2018-09-10

   3

  通道的类型如果是方法，性能会差吗？

  展开
• 
  阿海

  2019-01-05

   2

  运行了demo25.go, 发现结果是No candidate case is selected，原因跟
  var channels = [3]chan int{
      nil,
      make(chan int, 1),
      nil,
  }
  有关，因为channels[0], channels[2]都是nil，所以select case时阻塞，而channels[1]初始化为无缓存channel，当没有从channels[1]取值时，select case阻塞，所以一轮下来，没有符合的条件case，只能运行case default了。

  展开
• 
  heha37

  2018-11-05

   2

  当第二个boolean参数为false的时候，在相应的case中设置chan为nil零值，再次case求值的时候会遭遇阻塞，会屏蔽该case。

  展开

  作者回复: 是的。

• 
  许森森

  2018-09-14

   2

  1 发现channel是closed之后，重新make，使得为nil，保证一直 阻塞。
  
          i := 0
          for {
              select {
              case _, ok := <-c:
                  if !ok {
                      c = make(chan bool)
                      fmt.Println("!ok")
                  } else {
                      fmt.Println("c:", c)
                  }
              default:
                  time.Sleep(1e9) // 等待1秒钟
                  fmt.Println("default, ", i)
                  i = i + 1
                  if i > 3 {
                      return
                  }
              }
          }
  2
  return 直接退出程序
  break loop // 结合loop，会退出for循环
  goto end //结合end，跳转
  
      //在select语句与for语句联用时，怎样直接退出外层的for语句?
      tick := time.Tick(100 * time.Millisecond)
      boom := time.After(500 * time.Millisecond)
      //loop:
      for {
          select {
          case <-tick:
              fmt.Println("tick.")
          case <-boom:
              fmt.Println("BOOM!")
              // return //直接退出程序
              //break loop // 结合loop，会退出for循环
              goto end //结合end
          default:
              fmt.Println(" .")
              time.Sleep(50 * time.Millisecond)
          }
      }
  
  end:
      fmt.Println("END...")
  

  展开
• 
  左氧佛沙星...

  2019-03-25

   1

  老师好，demo25中的这段代码我没看懂，不是这个匹配上了吗？为啥没有执行呢？我理解应该打印The second candidate case is selected.。。。。
  ```
  case getChan(1) <- getNumber(1):
  ```
  能指点一下吗？

  展开

  作者回复: 因为 make(chan int) 初始化的是不带缓冲的通道。非缓冲通道只有在收发双方都就绪的情况下才能传递元素值，否则就阻塞。

• 
  Cxb

  2019-03-07

   1

  @王小勃
  demo25 不输出second candidate 原因应该是channels[1]是非缓冲通道，select语句检测到阻塞状态，所以case语句不成立。把channels[1]设置为缓冲通道，或者写个协程接受channels[1]就可以输出second candidate
  func main() {
      //go func() {
      //    fmt.Println(<-channels[1])
      //}()
      select {
      case getChan(0) <- getNumber(0):
          fmt.Println("The first candidate case is selected.")
      case getChan(1) <- getNumber(1):
          fmt.Println("The second candidate case is selected.")
      case getChan(2) <- getNumber(2):
          fmt.Println("The third candidate case is selected")
      default:
          fmt.Println("No candidate case is selected!")
      }
  }

  展开
• 
  一只傻哈皮

  2019-02-22

   1

  请问select伪随机执行的目的是什么呢？没太理解这样做的目的。

  作者回复: 这属于语言特性之一，没有什么特殊原因。你可以理解为避免case书写顺序影响到执行顺序。

• 
  王小勃

  2018-12-21

   1

  有个问题不明：demo25中 select为什么选择的不是第二个case输出？
  第二个case实际上在往channels[1] <- 2 ,那为什么不输出：The second candidate case is selected.
  package main
  
  import "fmt"
  
  var channels = [3]chan int{
      nil,
      make(chan int),
      nil,
  }
  
  var numbers = []int{1, 2, 3}
  
  func main() {
      select {
      case getChan(0) <- getNumber(0):
          fmt.Println("The first candidate case is selected.")
      case getChan(1) <- getNumber(1):
          fmt.Println("The second candidate case is selected.")
      case getChan(2) <- getNumber(2):
          fmt.Println("The third candidate case is selected")
      default:
          fmt.Println("No candidate case is selected!")
      }
  }
  
  func getNumber(i int) int {
      fmt.Printf("numbers[%d]\n", i)
      return numbers[i]
  }
  
  func getChan(i int) chan int {
      fmt.Printf("channels[%d]\n", i)
      return channels[i]
  }

  展开
• 
  到不了的塔

  2018-10-24

   1

  郝老师，请问第一题的答案是啥，不知道怎么屏蔽分支呢

  作者回复: 设置为nil就可以了。

• 
  一步

  2018-09-14

   1

  老师你上面的发送通道<-是代表，可以向通道中发送数据呢？那对于通道而言是不是就是，通道接收数据，叫做接收通道?

  展开

  作者回复: 只能向它发送数据的我简称为发送通道。

• 
  Neo

  2018-09-12

   1

  请问老师：
  select 分支选择规则中第5个："如果select语句发现同时有多个候选分支满足选择条件，那么它就会用一种伪随机算法在这些分支中选择一个执行" 随机选一个执行 那我们是不是就不能确定程序会执行哪一条与语句了？
  
  

  展开

  作者回复: 这种情况下是这样。

• 
  michael

  2018-09-09

   1

  第二个问题，可以将for select写到一个函数里面，用return的方式来跳出for循环
• 
  王腾飞

  2018-09-08

   1

  如何动态的调整select的channel，比如我能否select一个channel切片，然后根据需要调整切片的内容？

  作者回复: 切片不是并发安全的，在这种场景下最好不要用。

• 
  冰激凌的眼...

  2018-09-07

   1

  单向通道乍看没什么作用，但是看了后面文章，看到在函数传参、返回时可以通过双向通道的退化形成单向通道，就明白作者说的约束行为的意义了。

  展开