go-channel-goroutine实践2

niyuelin1990 · · 987 次点击 · · 开始浏览

这是一个创建于的文章，其中的信息可能已经有所发展或是发生改变。

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

目标：对列表数据进行逐个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)
}