egg_app/app/task/task_egg_energy_deal_fund_data.go

package task

import (
	"applet/app/task/svc"
	"math/rand"
	"time"
	"xorm.io/xorm"
)

// 处理价值投入
func taskEggEnergyDealFundData(eg *xorm.Engine) {
	for {
		if len(ch) > workerNum {
			time.Sleep(time.Millisecond * time.Duration(rand.Intn(1000)))
		} else {
			goto START
		}
	}
START:
	ch <- 1
	svc.EggEnergyDealFundData(eg)
	<-ch
}