commit

aarch64/pjisuv/master/service/produce_window.go

@@ -46,7 +46,7 @@ func PrepareTimeWindowProducerQueue() {
 	subscribersTimeMutexes := make([]sync.Mutex, len(commonConfig.SubscribeTopics))
 	subscribersMutexes := make([]sync.Mutex, len(commonConfig.SubscribeTopics))
 	for i, topic := range commonConfig.SubscribeTopics {
-		// !!!扩展的定时任务监听，牛逼的设计!!!扩展性拉满啦
+		// 增加了可扩展性
 		if topic == masterConfig.TopicOfCicvExtend {
 			go func() {
 				for {