liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

并发任务加入到管理

Browse Source
This commit is contained in:
Rosy-zhudan
2019-08-08 17:56:45 +08:00
parent fcb04c7f52
commit bc896e98e5
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
business/jxstore/cms/store_sku_check.go
View File

@@ -274,7 +274,7 @@ func CheckSkuDiffBetweenJxAndVendor(vendorIDList []int, storeIDList []int) {
return retVal, err return retVal, err
} }
taskParallel := tasksch.NewParallelTask("CheckSkuDiffBetweenJxAndVendor", tasksch.NewParallelConfig().SetParallelCount(parallelCount), ctx, taskFunc, jxStoreInfoList.Stores) taskParallel := tasksch.NewParallelTask("CheckSkuDiffBetweenJxAndVendor", tasksch.NewParallelConfig().SetParallelCount(parallelCount), ctx, taskFunc, jxStoreInfoList.Stores)
tasksch.HandleTask(taskParallel, task, false).Run() tasksch.HandleTask(taskParallel, task, true).Run()
_, err = taskParallel.GetResult(0) _, err = taskParallel.GetResult(0)
if err != nil { if err != nil {
baseapi.SugarLogger.Debugf("CheckSkuDiffBetweenJxAndVendor taskParallel error:%v", err) baseapi.SugarLogger.Debugf("CheckSkuDiffBetweenJxAndVendor taskParallel error:%v", err)
@@ -290,7 +290,7 @@ func CheckSkuDiffBetweenJxAndVendor(vendorIDList []int, storeIDList []int) {
return result, err return result, err
} }
taskSeq := tasksch.NewSeqTask("CheckSkuDiffBetweenJxAndVendor SeqTask", ctx, taskSeqFunc, 2) taskSeq := tasksch.NewSeqTask("CheckSkuDiffBetweenJxAndVendor SeqTask", ctx, taskSeqFunc, 2)
tasksch.HandleTask(taskSeq, nil, false).Run() tasksch.HandleTask(taskSeq, nil, true).Run()
} }
func WriteToExcel(task *tasksch.SeqTask, data map[int][]DiffData) { func WriteToExcel(task *tasksch.SeqTask, data map[int][]DiffData) {