Nikolay (Все сообщения пользователя)

local is_run = true

if _G.message then
    print = function(...) _G.message(table.concat({...}, ", ")) end
end

local task_queue = {}
local function AddActionResult(task, is_done, is_error, mes)
    if not task then return end
    if is_done then
        task.done         = true
        task.error        = false
        task.response_mes = tostring(mes or '')
    elseif is_error then
        task.done         = false
        task.error        = true
        task.response_mes = tostring(mes or '')
    end
end

local function Process(task)
    if not task then return end
    if not task.process then return end
    if not task.in_progress then task.in_progress = true end
    AddActionResult(task, task.process())
end

local function Dispatch()
    if not is_run then return end

    local count = 1
    while is_run and #task_queue > 0 do
        local task = task_queue[count]
        if task and not (task.done or task.error or task.stop) then
            Process(task)
        end
        if task and (task.done or task.error or task.stop) then
            task.in_progress    = false
            local response_mes  = ''
            if not task.silent or not task.done then
                if task.done then
                    response_mes = 'Задача выполнена успешно: '..tostring(task.description)
                elseif task.error then
                    response_mes = 'Задача не выполнена: '..tostring(task.description)..', по причине: '
                elseif task.stop then
                    response_mes = 'Задача остановлена: '..tostring(task.description)
                end
                print(response_mes)
                if (task.response_mes or '')~= '' then                    print('\t'..(task.response_mes or ''))
                end
                if type(task.done_callback) == 'function' then task.done_callback(task) end
                if type(task.err_callback) == 'function' then task.err_callback(task) end
            end
            table.sremove(task_queue, count)
            count = count - 1
        end
        if count + 1 >= #task_queue then
            if #task_queue == 0 then print('Очередь задач пуста') end
            return
        end
        count = count >= #task_queue and 1 or count + 1
    end
end

local function create_ds(ctx, done_callback, err_callback, wait_time)
    if not ctx then return end

    local ds, err = _G.CreateDataSource(ctx.class_code, ctx.sec_code, ctx.interval)
    if not ds then
        print(err, 3)
        return
    end

    ds.interval     = ctx.interval
    ds.class_code   = ctx.class_code
    ds.sec_code     = ctx.sec_code
    ds.description  = ctx.class_code..'|'..ctx.sec_code..', интервал '..tostring(ds.interval)
    ds.done_request = false
    ctx.ds          = ds

    print('Заказ данных '..ds.description)

    wait_time       = wait_time or 60
    local lt        = os.time()

    local task = {description = 'Заказ данных '..ds.description, ctx = ctx}

    task.process = function()
        if os.time() - lt >= wait_time then return false, true, 'Не удалось инициализировать инструменты за время '..tostring(wait_time)..'сек.' end
        local size = ds:Size()
        if size == 0 then return end
        ds.done_request = true
        return true, false, 'Получены бары '..ds.description..', размер: '..tostring(size)
    end
    task.done_callback  = done_callback
    task.err_callback   = err_callback

    task_queue[#task_queue+1] = task
end

local function counter(i, limit)
    local x = 0
    local task = {description = 'Счетчик до '..tostring(limit)}
    task.process = function()
        x = x + 1
        if x >= limit then
            return true, false, string.format('%i: Счетчик до %i завершен', i, limit)
        end
    end
    task_queue[#task_queue+1] = task
end

local  sec_list = {}
sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 1}
sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 2}
sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 5}
sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 10}
sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 20}
sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'GAZP', interval = 10}
sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'GAZP', interval = 2}
sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'GAZP', interval = 5}
sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'LKOH', interval = 5}
sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'FEES', interval = 5}
sec_list[#sec_list+1] = {class_code = 'SPBFUT', sec_code = 'SiZ5', interval = 5}
sec_list[#sec_list+1] = {class_code = 'SPBFUT', sec_code = 'RIZ5', interval = 5}
sec_list[#sec_list+1] = {class_code = 'SPBFUT', sec_code = 'RIZ5', interval = 15}
sec_list[#sec_list+1] = {class_code = 'SPBFUT', sec_code = 'SRZ5', interval = 30}

function main()
    for i = 1, #sec_list do
        counter(i, i*2)
        create_ds(sec_list[i])
    end
    while is_run do
        Dispatch()
        sleep(100)
    end
end

function OnStop()
    is_run = false
end