添加协程

3 years ago · 4ae2dda68a
parent c02ce7916f
commit 4ae2dda68a
1 changed files with 2 additions and 2 deletions
--- a/internal/cron/supply.go
+++ b/internal/cron/supply.go
@ -65,8 +65,8 @@ func (s *supplyTask) price() {
 		time.Sleep(time.Second * 3)
 		s.price()
 	}()
-	pool, _ := ants.NewPool(5)
-	if err := (skuMessage{}.Consume(supply.Api.Mq.SkuPriceChangeQueue(), false, 5, func(message skuMessage, delivery amqp.Delivery) {
+	pool, _ := ants.NewPool(30)
+	if err := (skuMessage{}.Consume(supply.Api.Mq.SkuPriceChangeQueue(), false, 30, func(message skuMessage, delivery amqp.Delivery) {
 		pool.Submit(func() {
 			defer delivery.Ack(false)
 			if err := third.SupplyLogic.SyncPrice([]uint{message.SkuId}); err != nil {