go并发之美·多个操作的分发及限流

r囧r小猫 2022-12-11 15:00 156阅读 0赞

缘分随风飘荡

缘尽此生也守望

你我在凝望那一刻

心中有泪飘降...

code is graceful , thoughts are precious.

>     今天又萌生一个想法，动手来实现下看看！
>     模拟进行多个操作的分发及限流：模拟许多人在火车站窗口办理相关事情的情景。
>     我们假设窗口分为三类A\B\C：买票窗口、改签/退票窗口、老弱病残孕爱心窗口，每种有多个窗口
>     受大厅大小限制，A、B每个窗口排队最多5人，C类窗口最多排队3人，总有很多人在排队，可以想象下
>     A类下面共3个窗口，即排队最多15人
>     B类下面共3个窗口，即排队最多15人
>     C类下面共2个窗口，即排队最多6人
>     每个人办理都有一定耗时

代码是优美的，文章是优美的，一切都是美好的，个人原创，欢迎阅读。

type Window struct {
    	WinName  string
    	UserName string
    	RandNum  int // 每个人自己额外的耗时，取随机数
    }
    
    func main() {
    	// 各类事情总窗口执行队列,A、B类窗口正在办理的人最多三个(每个窗口各一个正在办理)
    	chA, chB, chC := make(chan *Window, 3), make(chan *Window, 3), make(chan *Window, 2)
    	waitChA, waitChB, waitChC := make(chan *Window, 12), make(chan *Window, 12), make(chan *Window, 12) // 各类窗口等待队列
    	// 派发people到各个窗口
    	go func() {
    		for i := 1; ; i++ {
    			//fmt.Println("第" + strconv.Itoa(i) + "次循环")
    			name := "王" + strconv.Itoa(i)
    			num := rand.Intn(5) // 随机写入某个通道
    			if num == 0 {
    				obj := &Window{UserName: name, WinName: "C", RandNum: num}
    				select {
    				case chC <- obj:
    				default:
    					fmt.Println(fmt.Sprintf("您好，C窗口当前排队已满，请稍后...%v开始排队,排队时间=%v", obj.UserName, time.Now().Unix()))
    					waitChC <- obj
    					continue
    				}
    			} else if num == 1 || num == 3 {
    				obj := &Window{UserName: name, WinName: "B", RandNum: num - 1}
    				select {
    				case chB <- obj:
    				default:
    					fmt.Println(fmt.Sprintf("您好，B窗口当前排队已满，请稍后...%v开始排队,排队时间=%v", obj.UserName, time.Now().Unix()))
    					waitChB <- obj
    					continue
    				}
    			} else if num == 2 || num == 4 {
    				obj := &Window{UserName: name, WinName: "A", RandNum: num - 1}
    				select {
    				case chA <- obj: // 表明三个窗口中有一个窗口现在闲着可以直接去办理，否则进入到等待队列
    				default:
    					fmt.Println(fmt.Sprintf("您好，A窗口当前排队已满，请稍后...%v开始排队,排队时间=%v", obj.UserName, time.Now().Unix()))
    					waitChA <- obj
    					continue
    				}
    			}
    
    			sleepT1, sleepT2 := rand.Intn(100), rand.Intn(1000)
    			time.Sleep(time.Millisecond * time.Duration(sleepT2-sleepT1)) // 给业务员一点缓冲的时间
    		}
    	}()
    
    	// 办理A类窗口相关事情
    	go func() {
    		for {
    			select {
    			case aThing := <-chA:
    				sleepTime := aThing.RandNum + 1
    				time.Sleep(time.Second * time.Duration(sleepTime)) // 办事的总耗时
    				fmt.Println(fmt.Sprintf("【A】%s在A窗口办理完毕,办理结束时间=%v,共耗时%v秒.", aThing.UserName, time.Now().Unix(), sleepTime))
    			}
    		}
    	}()
    
    	// 办理B类窗口相关事情
    	go func() {
    		for {
    			select {
    			case bThing := <-chB:
    				sleepTime := bThing.RandNum + 1
    				time.Sleep(time.Second * time.Duration(sleepTime)) // 办事的总耗时
    				fmt.Println(fmt.Sprintf("【B】%s在B窗口办理完毕,办理结束时间=%v,共耗时%v秒.", bThing.UserName, time.Now().Unix(), sleepTime))
    			}
    		}
    	}()
    
    	// 办理C类窗口相关事情
    	go func() {
    		for {
    			select {
    			case cThing := <-chC:
    				sleepTime := cThing.RandNum + 1
    				time.Sleep(time.Second * time.Duration(sleepTime)) // 办事的总耗时
    				fmt.Println(fmt.Sprintf("【C】%s在C窗口办理完毕,办理结束时间=%v,共耗时%v秒.", cThing.UserName, time.Now().Unix(), sleepTime))
    			}
    		}
    	}()
    
    	// 处理等待队列A
    	go func() {
    		for {
    			select {
    			case userA := <-waitChA:
    			ALoop:
    				for {
    					select {
    					case chA <- userA:
    						break ALoop // 排队的人少于3人，可以排上了(往执行队列写入)
    					default:
    						fmt.Println("[wait-A]:", userA.UserName, "等待中...")
    						time.Sleep(time.Second * 2)
    					}
    				}
    			default:
    
    			}
    		}
    	}()
    
    	// 处理等待队列B
    	go func() {
    		for {
    			select {
    			case userB := <-waitChB:
    			BLoop:
    				for {
    					select {
    					case chB <- userB:
    						break BLoop
    					default:
    						fmt.Println("[wait-B]:", userB.UserName, "等待中...")
    						time.Sleep(time.Second * 2)
    					}
    				}
    			default:
    
    			}
    		}
    	}()
    
    	// 处理等待队列C
    	go func() {
    		for {
    			select {
    			case userC := <-waitChC:
    			CLoop:
    				for {
    					select {
    					case chC <- userC:
    						break CLoop
    					default:
    						fmt.Println("[wait-C]:", userC.UserName, "等待中...")
    						time.Sleep(time.Second * 2)
    					}
    				}
    			default:
    
    			}
    		}
    	}()
    
    	for !false {
    		fmt.Print()
    	}
    }

看看效果：

【B】王1在B窗口办理完毕,办理结束时间=1601649175,共耗时1秒.
    【C】王3在C窗口办理完毕,办理结束时间=1601649176,共耗时1秒.
    【C】王4在C窗口办理完毕,办理结束时间=1601649177,共耗时1秒.
    您好，A窗口当前排队已满，请稍后...王9开始排队,排队时间=1601649178
    您好，A窗口当前排队已满，请稍后...王10开始排队,排队时间=1601649178
    您好，A窗口当前排队已满，请稍后...王11开始排队,排队时间=1601649178
    [wait-A]: 王9 等待中...
    您好，A窗口当前排队已满，请稍后...王15开始排队,排队时间=1601649179
    您好，B窗口当前排队已满，请稍后...王16开始排队,排队时间=1601649179
    [wait-B]: 王16 等待中...
    【B】王8在B窗口办理完毕,办理结束时间=1601649179,共耗时1秒.
    【A】王2在A窗口办理完毕,办理结束时间=1601649179,共耗时4秒.
    【C】王17在C窗口办理完毕,办理结束时间=1601649180,共耗时1秒.
    您好，A窗口当前排队已满，请稍后...王21开始排队,排队时间=1601649180
    您好，B窗口当前排队已满，请稍后...王22开始排队,排队时间=1601649180
    您好，A窗口当前排队已满，请稍后...王23开始排队,排队时间=1601649180
    您好，A窗口当前排队已满，请稍后...王24开始排队,排队时间=1601649180
    [wait-A]: 王9 等待中...
    【C】王18在C窗口办理完毕,办理结束时间=1601649181,共耗时1秒.
    [wait-B]: 王16 等待中...
    您好，B窗口当前排队已满，请稍后...王26开始排队,排队时间=1601649181
    您好，B窗口当前排队已满，请稍后...王27开始排队,排队时间=1601649181
    【A】王5在A窗口办理完毕,办理结束时间=1601649181,共耗时2秒.
    您好，B窗口当前排队已满，请稍后...王30开始排队,排队时间=1601649181
    您好，B窗口当前排队已满，请稍后...王31开始排队,排队时间=1601649181
    【C】王25在C窗口办理完毕,办理结束时间=1601649182,共耗时1秒.
    【B】王12在B窗口办理完毕,办理结束时间=1601649182,共耗时3秒.
    [wait-A]: 王9 等待中...
    您好，B窗口当前排队已满，请稍后...王34开始排队,排队时间=1601649182
    您好，A窗口当前排队已满，请稍后...王35开始排队,排队时间=1601649182
    您好，A窗口当前排队已满，请稍后...王36开始排队,排队时间=1601649182
    您好，A窗口当前排队已满，请稍后...王37开始排队,排队时间=1601649182
    您好，B窗口当前排队已满，请稍后...王38开始排队,排队时间=1601649182
    您好，B窗口当前排队已满，请稍后...王39开始排队,排队时间=1601649182
    【C】王28在C窗口办理完毕,办理结束时间=1601649183,共耗时1秒.
    [wait-B]: 王16 等待中...
    【B】王13在B窗口办理完毕,办理结束时间=1601649183,共耗时1秒.
    您好，A窗口当前排队已满，请稍后...王41开始排队,排队时间=1601649183
    您好，B窗口当前排队已满，请稍后...王43开始排队,排队时间=1601649183
    您好，B窗口当前排队已满，请稍后...王44开始排队,排队时间=1601649183
    您好，B窗口当前排队已满，请稍后...王45开始排队,排队时间=1601649183
    您好，A窗口当前排队已满，请稍后...王46开始排队,排队时间=1601649183
    您好，B窗口当前排队已满，请稍后...王47开始排队,排队时间=1601649183
    您好，B窗口当前排队已满，请稍后...王48开始排队,排队时间=1601649183
    【C】王29在C窗口办理完毕,办理结束时间=1601649184,共耗时1秒.
    【B】王14在B窗口办理完毕,办理结束时间=1601649184,共耗时1秒.
    [wait-A]: 王9 等待中...
    [wait-B]: 王22 等待中...
    您好，B窗口当前排队已满，请稍后...王49开始排队,排队时间=1601649185
    【C】王40在C窗口办理完毕,办理结束时间=1601649185,共耗时1秒.
    【A】王6在A窗口办理完毕,办理结束时间=1601649185,共耗时4秒.
    [wait-A]: 王10 等待中...
    [wait-B]: 王22 等待中...
    【B】王19在B窗口办理完毕,办理结束时间=1601649187,共耗时3秒.
    【A】王7在A窗口办理完毕,办理结束时间=1601649187,共耗时2秒.
    [wait-A]: 王11 等待中...
    [wait-B]: 王26 等待中...
    您好，A窗口当前排队已满，请稍后...王50开始排队,排队时间=1601649189
    您好，B窗口当前排队已满，请稍后...王52开始排队,排队时间=1601649189
    【C】王51在C窗口办理完毕,办理结束时间=1601649190,共耗时1秒.
    【B】王33在B窗口办理完毕,办理结束时间=1601649190,共耗时3秒.
    [wait-A]: 王11 等待中...
    [wait-B]: 王27 等待中...
    您好，B窗口当前排队已满，请稍后...王54开始排队,排队时间=1601649191
    【A】王20在A窗口办理完毕,办理结束时间=1601649191,共耗时4秒.
    【C】王53在C窗口办理完毕,办理结束时间=1601649192,共耗时1秒.
    [wait-A]: 王15 等待中...
    [wait-B]: 王27 等待中...
    【B】王42在B窗口办理完毕,办理结束时间=1601649193,共耗时3秒.
    【A】王32在A窗口办理完毕,办理结束时间=1601649193,共耗时2秒.
    【B】王16在B窗口办理完毕,办理结束时间=1601649194,共耗时1秒.
    [wait-A]: 王21 等待中...
    [wait-B]: 王31 等待中...
    【B】王22在B窗口办理完毕,办理结束时间=1601649195,共耗时1秒.
    【A】王9在A窗口办理完毕,办理结束时间=1601649195,共耗时2秒.
    【C】王55在C窗口办理完毕,办理结束时间=1601649196,共耗时1秒.
    [wait-A]: 王23 等待中...
    您好，A窗口当前排队已满，请稍后...王59开始排队,排队时间=1601649196
    您好，A窗口当前排队已满，请稍后...王60开始排队,排队时间=1601649196
    您好，A窗口当前排队已满，请稍后...王61开始排队,排队时间=1601649196
    您好，A窗口当前排队已满，请稍后...王62开始排队,排队时间=1601649196
    您好，B窗口当前排队已满，请稍后...王63开始排队,排队时间=1601649196
    您好，A窗口当前排队已满，请稍后...王64开始排队,排队时间=1601649196
    您好，B窗口当前排队已满，请稍后...王65开始排队,排队时间=1601649196
    [wait-B]: 王31 等待中...
    【C】王56在C窗口办理完毕,办理结束时间=1601649197,共耗时1秒.
    【A】王10在A窗口办理完毕,办理结束时间=1601649197,共耗时2秒.
    【C】王57在C窗口办理完毕,办理结束时间=1601649198,共耗时1秒.
    【B】王26在B窗口办理完毕,办理结束时间=1601649198,共耗时3秒.
    [wait-A]: 王24 等待中...
    [wait-B]: 王34 等待中...
    您好，A窗口当前排队已满，请稍后...王66开始排队,排队时间=1601649199
    您好，B窗口当前排队已满，请稍后...王67开始排队,排队时间=1601649199
    【A】王11在A窗口办理完毕,办理结束时间=1601649199,共耗时2秒.
    [wait-A]: 王35 等待中...
    [wait-B]: 王34 等待中...
    【B】王27在B窗口办理完毕,办理结束时间=1601649201,共耗时3秒.
    【A】王15在A窗口办理完毕,办理结束时间=1601649201,共耗时2秒.
    [wait-A]: 王36 等待中...
    [wait-B]: 王38 等待中...
    您好，A窗口当前排队已满，请稍后...王68开始排队,排队时间=1601649203
    您好，B窗口当前排队已满，请稍后...王69开始排队,排队时间=1601649203
    【A】王21在A窗口办理完毕,办理结束时间=1601649203,共耗时2秒.
    【B】王30在B窗口办理完毕,办理结束时间=1601649204,共耗时3秒.
    [wait-A]: 王37 等待中...
    [wait-B]: 王39 等待中...
    您好，A窗口当前排队已满，请稍后...王71开始排队,排队时间=1601649205
    您好，B窗口当前排队已满，请稍后...王72开始排队,排队时间=1601649205
    【C】王70在C窗口办理完毕,办理结束时间=1601649206,共耗时1秒.
    [wait-A]: 王37 等待中...
    [wait-B]: 王39 等待中...
    【B】王58在B窗口办理完毕,办理结束时间=1601649207,共耗时3秒.
    【A】王23在A窗口办理完毕,办理结束时间=1601649207,共耗时4秒.
    【B】王31在B窗口办理完毕,办理结束时间=1601649208,共耗时1秒.
    [wait-A]: 王41 等待中...
    [wait-B]: 王44 等待中...

随风随浪飘荡

随着一生里的浪

你我在重叠的那一刻

顷刻各在一方...

**go并发之美·干货好文合集：**

[go并发之美·redis篇·接口幂等性设计实现][go_redis]

[go并发之美·redis篇·实现实时排行榜][go_redis 1]

[go并发日记·多goroutine并发安全的操作共享变量][go_goroutine]

[go并发日记·常用并发场景中的并发控制思路与方案][go]

[go并发日记·避免goroutine泄漏/实现协程可控][go_goroutine 1]

[go并发日记·深入理解go语言channel与goroutine阻塞][go_go_channel_goroutine]

[go并发日记·基于channel优雅的进行并发控制][go_channel]

[go并发日记·WaitGroup并发控制探索及实际场景运用][go_WaitGroup]

[channel死锁的情况分析][channel]

[go并发之美·B操作伴随A操作(B和A同步)][go_B_A_B_A]

[go多函数并发通用工具的设计与实现][go 1]

[go_redis]: https://lan6193.blog.csdn.net/article/details/108938119
[go_redis 1]: https://lan6193.blog.csdn.net/article/details/108931188
[go_goroutine]: https://lan6193.blog.csdn.net/article/details/105715373
[go]: https://lan6193.blog.csdn.net/article/details/108670428
[go_goroutine 1]: https://lan6193.blog.csdn.net/article/details/105559568
[go_go_channel_goroutine]: https://lan6193.blog.csdn.net/article/details/97528721
[go_channel]: https://lan6193.blog.csdn.net/article/details/101201408
[go_WaitGroup]: https://lan6193.blog.csdn.net/article/details/100887891
[channel]: https://lan6193.blog.csdn.net/article/details/97656420
[go_B_A_B_A]: https://lan6193.blog.csdn.net/article/details/108901339
[go 1]: https://lan6193.blog.csdn.net/article/details/103298105