package task import ( "applet/app/task/svc" "math/rand" "time" "xorm.io/xorm" ) // 取消订单 func taskCancelOrder(eg *xorm.Engine, dbName string) { for { if len(ch) > workerNum { time.Sleep(time.Millisecond * time.Duration(rand.Intn(1000))) } else { goto START } } START: ch <- 1 svc.CancelOrder(eg, dbName) <-ch }