go-channel-goroutine实践2

需求:获取数组数据,对数据的原始数据逐个进行处理,后返回处理完的数据

目标:对列表数据进行逐个goroutine并发处理,再用select整合,返回数据

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)
}

本文来自:CSDN博客

感谢作者:niyuelin1990

查看原文:go-channel-goroutine实践2

• 编辑
• 预览