reflect.Select 函数是需要为什么？我认为这是因为通道必须是反射值？

Question

在什么情况下会需要reflect.Select？我找到了例子，但 Select 的使用似乎是做作的。任何示例，其中 reflect.Select 比正常选择是必要的？

Answer 1

最近有一篇来自 MongoDB 的人的文章。显然，此代码在其实用mongodump程序中用于生产。

使用的具体代码reflect.Select如下所示（来自文章）：

// Run multiplexer until it receives an EOF on the control channel.

func (mux *Multiplexer) Run() {

    for {

        index, value, recv := reflect.Select(mux.selectCases)

        EOF := !recv

        // note that the control channel is always at index 0

        if index == 0 {

            if EOF {

                return

            }

            muxInput, _ := value.Interface().(*muxInputSource)

            mux.selectCases = append(mux.selectCases, reflect.SelectCase{

                Dir:  reflect.SelectRecv,

                Chan: reflect.ValueOf(muxInput.collection),

                Send: reflect.Value{},

            })

        } else {

            if EOF {

                mux.writeEOF()

                mux.selectCases = append(mux.selectCases[:index], mux.selectCases[index+1:]...)

            } else {

                document, _ := value.Interface().([]byte)

                mux.writeDocument(document)[]

            }

        }

    }

}

我认为他们使用reflect.Select而不是直接的原因select：

goroutine 的数量（以及通道的数量）是在运行时确定的（使用-j标志）。事实上，它似乎随着append. （归功于@cnicutar 的评论）

通道的类型在运行时确定。这允许他们的muxInput.collection类型是任何它想要的。（归功于@JimB 的评论）

Answer 2

如果您的频道是固定的，您可以使用选择观看它们；但是，如果您的频道不固定并且您想观看它们，则可以使用 reflect.Select。

有一些代码片段

var (

      events  []reflect.SelectCase

      err     error

      lenHdr  = 3 // zk conn event chan, shutdown chan, children refresh chan

      lenCW   = len(z.ChildWatches)    // a channel slice:chan ChildWatche

      lenDW   = len(z.DataWatches)     //a channel slice:chan DataWatche

      lenEN   = len(z.EphemeralNodes)  //a channel slice: chan EphemeralNode

  )

  events = make([]reflect.SelectCase, lenHdr+lenCW+lenDW+lenEN)

  events[0] = reflect.SelectCase{Dir: reflect.SelectRecv, Chan: reflect.ValueOf(FreshChanConEvent())} // kick off the event loop

  events[1] = reflect.SelectCase{Dir: reflect.SelectRecv, Chan: reflect.ValueOf(z.shutdownChan)}

  events[2] = reflect.SelectCase{Dir: reflect.SelectRecv, Chan: reflect.ValueOf(z.refreshChildChan)}

  for i, _ := range z.ChildWatches {

      events[lenHdr+i] = reflect.SelectCase{Dir: reflect.SelectRecv, Chan: reflect.Zero(reflect.TypeOf((chan zk.Event)(nil)))}

  }

  for i, _ := range z.DataWatches {

      events[lenHdr+lenCW+i] = reflect.SelectCase{Dir: reflect.SelectRecv, Chan: reflect.Zero(reflect.TypeOf((chan zk.Event)(nil)))}

  }

  for i, info := range z.EphemeralNodes {

    events[lenHdr+lenCW+lenDW+i] = reflect.SelectCase{Dir: reflect.SelectRecv, Chan: reflect.ValueOf(info.Ch)}

  }

  for {

    chosen, value, ok := reflect.Select(events)

    if chosen == xxxxx {...}

这段代码是看频道数组（z.ChildWatches、z.DataWatches、z.EphemeralNodes）