多线程批量任务

工具

模板类库

创建日期: 2019-07-31 16:19:52

最后修改: 7 年前

复制: 37

点击次数: 2450

一拳男孩

关注

关注者


            
            
            
    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并且获取结果

策略源码

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)

策略参数