1. Square
2. 多线程批量任务

多线程批量任务

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

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

$.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)
}

$.wait = function(cmdList, maxConcurrent, retry) {
    retry = retry || true
    maxConcurrent = Math.min(cmdList.length, maxConcurrent || 5)
    var total = Math.ceil(cmdList.length / maxConcurrent)
    return _.reduce(_.range(total), function(beforeResultList, currentPage) {
        var lastCmdList = cmdList.slice(currentPage * maxConcurrent, currentPage * maxConcurrent + maxConcurrent)
        while (1) {
            lastCmdList = _.map(lastCmdList, function(cmd) {
                var args = cmd.args
                if (cmd.result == null) {
                    var ret = cmd.defer.wait()
                    if (ret != null) {
                        return _.extend(cmd, {
                            result: ret
                        })
                    } else if (retry === true) {
                        return _.extend(cmd, {
                            defer: args[0].Go.apply(args[0], args.slice(1)),
                            result: null
                        })
                    }
                }
                return cmd
            })
            var isFinished = _.every(lastCmdList, function(cmd) {
                return cmd.result
            })
            if (isFinished) {
                break
            }
            Sleep(RETRY_INTERVAL * 1000)
        }
        var newResultList = lastCmdList.map(function(cmd) {
            return cmd.result
        })
        if (currentPage + 1 < total) {
            Sleep(1000)
        }
        return beforeResultList.concat(newResultList)
    }, [])
}

• 干货-下单量精度和价格精度-适用各个交易所
• okex订单薄校验checksum算法函数
• JavaScript版K线数据行情收集器
• BSC Transaction
• 三大交易所止盈止损集成类库
• 获取持仓均价你用对了吗？
• 【定投】【新手入门】每周100USDT-定期定额 (100USDT Invested Every Week - Regular Fixed Investment)
• 火币U合约资金划转插件
• OK确认无法提币交易对
• 币安合约websocket接口查询持仓账户范例
• 期货基础策略

• 单商品小卖部策略V2.0_年化130%
• 牛熊猴市判断V1.0_区班主
• 单货币动态均衡V1.0_区班主
• 经典均线策略V1.0_区班主注释简化
• SeamlessConnWS
• 数字货币期货现货差价监控
• HUSD/USD稳定币套利
• C++期货高频套币策略OKEX Websocket版
• 火币点卡
• 时间格式工具
• 钉钉推送
• 火币精度
• OKEx跨期对冲策略
• 【海龟汤策略】反趋势交易策略
• RSI统计套利策略
• OKEX期现对冲
• 均线策略范例02
• DMI 测试范例
• 动态平衡策略 python 版
• MACD画图范例

fmzero 咋这牛逼啊

小草 不错