【golang】go-channel-goroutine实践2

type  money_per struct{
id int
name string
money float64
}
type MoneyHandler interface {
BatchDeal(m money_per)
}
type MoneyHandlerImpl struct {
}

func getMoneyHandler() MoneyHandler  {
return &MoneyHandlerImpl{}
}

var moneyPers = make([]money_per, 10)
var mchan = make(chan money_per, 100)

//初始化
func init()  {
for  i :=0; i<10 ;i++  {
var moneyPer = money_per{i, "ww"+strconv.Itoa(i), float64(i)}
moneyPers[i] = moneyPer
}
}

//业务处理
func (monnryHandler MoneyHandlerImpl)BatchDeal(m money_per) {
m.money +=11.0
time.Sleep(time.Second)
mchan <- m
}

func main() {
fmt.Println(moneyPers, cap(moneyPers), len(moneyPers))
t1 := time.Now()
moneyHandler := getMoneyHandler()
for mm := range moneyPers{
fmt.Println(moneyPers[mm])
go moneyHandler.BatchDeal(moneyPers[mm])
}
elapsed0 := time.Since(t1)
fmt.Println("App elapsed0: ", elapsed0)
rm := make([]money_per,10)
for  i :=0; i<10 ;i++  {
//m := <-mchan
//rm[m.id] = m
//fmt.Println(m)
select { // select轮询机制
case m := <- mchan:
fmt.Println(m)
rm[m.id] = m
}
}
elapsed := time.Since(t1)
fmt.Println("App elapsed: ", elapsed)
}