@@ -742,7 +742,7 @@ func (s *subscribePush) DefaultDatas(spqp *SubPushQueryParam) (hasNextPage bool,
now := time.Now()
var (
wg = &sync.WaitGroup{}
- wc = make(chan bool, 20)
+ wc = make(chan bool, scd.Size/pageSize)
)
for _, v := range *list {
go func(v map[string]interface{}) {
