11.7 并发模式(下)

一、同时等待多个任务第二种写法

使用select去写

func fanInSelect(c1, c2 chan string) chan string {
	c := make(chan string)
	go func() {
		for {
			select {
			case m := <-c1:
				c <- m
			case m := <-c2:
				c <- m
			}
		}
	}()

	return c
}

二、同时等待多个任务选择条件

1. 已知chan数量，使用select写

2. 未知chan数量

   // 同时等待多个服务
   func fanIn(chs ...chan string) chan string {
   	c := make(chan string)
   	for _, ch := range chs {
   		chCopy := ch // 防止多个chan只会返回最后一个chan，坑！！！
   		go func() {
   			for {
   				c <- <-chCopy
   			}
   		}()
   	}
   	return c
   }
   
   // 或者解决办法
   // 同时等待多个服务
   func fanIn(chs ...chan string) chan string {
   	c := make(chan string)
   	for _, ch := range chs {
   		go func(in chan string) {  // 传参方式解决
   			for {
   				c <- <-in
   			}
   		}(ch)  // 注意这里
   	}
   	return c
   }