文章目录
- 扇出模式
- reflectSelect 方式
扇出模式
有扇入模式,就有扇出模式,扇出模式是和扇入模式相反的。扇出模式只有一个输入源 Channel,有多个目标 Channel,扇出比就是 1 比目标 Channel 数的值,经常用在设计模式中的观察者模式中(观察者设计模式定义了对象间的一种一对多的组合关系。这样一来,一个对象的状态发生变化时,所有依赖于它的对象都会得到通知并自动刷新)。在观察者模式中,数据变动后,多个观察者都会收到这个变更信号。下面是一个扇出模式的实现。从源 Channel 取出一个数据后,依次发送给目标 Channel。在发送给目标 Channel 的时候,可以同步发送,也可以异步发送:
// 扇出模式只有一个输入源 Channel,有多个目标 Channel,扇出比就是 1 比目标 Channel 数的值
func fanOut(ch <-chan interface{}, out []chan interface{}, async bool) {go func() {defer func() { //退出时关闭所有的输出chanfor i := 0; i < len(out); i++ {close(out[i])}}()for v := range ch { // 从输入chan中读取数据v := v // 局部变量 v,以便在循环内部的闭包中使用for i := 0; i < len(out); i++ {i := i // 一个局部变量 i,以便在循环内部的闭包中使用if async {go func() {out[i] <- v // 放入到输出chan中,异步方式}()} else {out[i] <- v // 放入到输出chan中,同步方式}}}}()}
reflectSelect 方式
// 实现扇出模式的反射方式,将数据从一个通道发送到多个目标通道
func fanOutReflect2(ch <-chan interface{}, out []chan interface{}) {// 输入通道输出通道同时在一个cases 中cases := make([]reflect.SelectCase, len(out)+1)// Create a case for the input channel// 接收通道,监听,有数据即可发送cases[0] = reflect.SelectCase{Dir: reflect.SelectRecv, // case <-Chan: 从一个通道发出Chan: reflect.ValueOf(ch),}// Create cases for the output channels// 发送通道,监听,for i := 0; i < len(out); i++ {cases[i+1] = reflect.SelectCase{Dir: reflect.SelectSend, // Chan <- Send: 发到多个目标通道Chan: reflect.ValueOf(out[i]),}}for {chosen, recv, _ := reflect.Select(cases)if chosen == 0 {// Data received from the input channel 从输入通道接收的数据v := recv.Interface()for i := 1; i < len(cases); i++ {// Send the data to all output channels 将数据发送到所有输出通道cases[i].Send = reflect.ValueOf(v)}} else {// Data sent to an output channel 发送到输出通道的数据// 把接收通道的数据置空cases[chosen].Send = reflect.Value{}}}
}