多线程批量任务

Tool

Template

Created: 2019-07-31 16:19:52

Last modified: 7 years ago

Copy: 37

一拳男孩

Followers


            
            
            
    var tasks = $.go([
        [exchange, 'GetDepth'],
        [exchange, 'GetTicker'],
    ])
    var retList = $.wait(tasks)
    Log(retList[0])
    Log(retList[1])

$.go()

批量执行Go
参数类型二维数组


            
            
            
   [
        [exchange, 'GetDepth'],
        [exchange, 'GetTicker'],
    ]

返回值 cmdList 数组

$.wait(cmdList)

获取结果

$.gowait()

执行Go并且获取结果

Source

JavaScript

$.go = function(tasks) {
    return _.map(tasks, function(args) {
        return {
            result: null,
            args: args,
            defer: args[0].Go.apply(args[0], args.slice(1))
        }
    })
}

$.gowait = function(tasks, maxConcurrent, retry) {
    return $.wait($.go(tasks), maxConcurrent, retry)

Strategy parameters