关于select和channel数组的配合使用

可以用标准包reflect中的reflect.Select()函数来处理。给你写了个简单的例子：

package main

import (
    "fmt"
    "math/rand"
    "reflect"
    "time"
)

type (
    product struct {
        id  int // 生产者序号
        val int // 产品
    }
    producer struct {
        id   int // 序号
        chnl chan *product
    }
)

var (
    producerList []*producer
    notifynew    chan int
    updatedone   chan int
)

func main() {

    rand.Seed(time.Now().Unix())
    notifynew = make(chan int, 1)
    updatedone = make(chan int, 1)
    ticker := time.NewTicker(time.Second)

    cases := update(ticker)

    for {
        chose, value, _ := reflect.Select(cases)
        switch chose {
        case 0: // 有新的生产者
            cases = update(ticker)
            updatedone <- 1
        case 1:
            // 创建新的生产者
            if len(producerList) < 5 {
                go newproducer()
            }
        default:
            item := value.Interface().(*product)
            fmt.Printf("消费: 值=%d 生产者=%d\n", item.val, item.id)
        }
    }
}

func update(ticker *time.Ticker) (cases []reflect.SelectCase) {

    // 新生产者通知
    selectcase := reflect.SelectCase{
        Dir:  reflect.SelectRecv,
        Chan: reflect.ValueOf(notifynew),
    }
    cases = append(cases, selectcase)

    // 定时器
    selectcase = reflect.SelectCase{
        Dir:  reflect.SelectRecv,
        Chan: reflect.ValueOf(ticker.C),
    }
    cases = append(cases, selectcase)

    // 每个生产者
    for _, item := range producerList {
        selectcase = reflect.SelectCase{
            Dir:  reflect.SelectRecv,
            Chan: reflect.ValueOf(item.chnl),
        }
        cases = append(cases, selectcase)
    }
    return
}

func newproducer() {
    newitem := &producer{
        id:   len(producerList) + 1,
        chnl: make(chan *product, 100),
    }
    producerList = append(producerList, newitem)
    notifynew <- 1
    <-updatedone
    go newitem.run()
}

func (this *producer) run() {
    for {
        time.Sleep(time.Duration(int(time.Millisecond) * (rand.Intn(1000) + 1)))
        item := &product{
            id:  this.id,
            val: rand.Intn(1000),
        }
        fmt.Printf("生产: 值=%d 生产者=%d\n", item.val, item.id)
        this.chnl <- item
    }
}

嗯，多谢，刚刚了解了一下reflect。

很感谢，非常有用。