diff --git a/internal/cron/supply.go b/internal/cron/supply.go
index 9a89637..53c64bf 100644
--- a/internal/cron/supply.go
+++ b/internal/cron/supply.go
@@ -88,8 +88,8 @@ func (s *supplyTask) data() {
 		time.Sleep(time.Second * 3)
 		s.data()
 	}()
-	pool, _ := ants.NewPool(5)
-	if err := (skuMessage{}.Consume(supply.Api.Mq.SkuChangeQueue(), false, 5, func(message skuMessage, delivery amqp.Delivery) {
+	pool, _ := ants.NewPool(30)
+	if err := (skuMessage{}.Consume(supply.Api.Mq.SkuChangeQueue(), false, 30, func(message skuMessage, delivery amqp.Delivery) {
 		pool.Submit(func() {
 			defer delivery.Ack(false)
 			if err := third.SupplyLogic.SyncData([]uint{message.SkuId}); err != nil {