Работа колбеков

local run = true
function OnStop()
  run = nil
end

function main()
  local n = getNumberOf("all_trades")
  local m = n
  message("Num all trades: " .. n)
  repeat
    sleep(1)
    m = n; n = getNumberOf("all_trades")
    if run == nil then return end
  until n < m
  local t = os.clock()
  message("Num all trades: " .. m)
  repeat
    sleep(1)
    n = getNumberOf("all_trades")
    if run == nil then return end
  until n >= m         -- ожидание пока прокачаются все сделки
  t = os.clock() - t
  message(string.format("%.1f s; num: %u; avg: %.3f ms", t, n, t / n * 1000))
end

local run = true
function OnStop()
  run = nil
end

function main()
  local n = getNumberOf("all_trades")
  local m = n
  message("Num all trades: " .. n)
  repeat
    sleep(1)
    m = n; n = getNumberOf("all_trades")
    if run == nil then return end
  until n < m
  local t = os.clock()
  message("Num all trades: " .. m)
  repeat
    sleep(1)
    n = getNumberOf("all_trades")
    if run == nil then return end
  until n >= m         -- ожидание пока прокачаются все сделки
  t = os.clock() - t
  message(string.format("with OnAllTrade:  %.1f s; num: %u; avg: %.3f ms", t, n, t / n * 1000))
end

function OnAllTrade(alltrade) end

40.2 s; num: 5719275; avg: 0.007 ms
with OnAllTrade:  85.7 s; num: 5731311; avg: 0.015 ms

local path = _G.getScriptPath()
package.path = path.."/?.lua;"

local bl1 = require('big_lib')
local bl2 = require('big_lib2')
local bl3 = require('big_lib3')
local bl4 = require('big_lib4')

local logFile

local function log_tostring(...)
    local n = select('#', ...)
    if n == 1 then
    return tostring(select(1, ...))
    end
    local t = {}
    for i = 1, n do
    t[#t + 1] = tostring((select(i, ...)))
    end
    return table.concat(t, " ")
end

local function log(...)
    if logFile==nil then return end
    logFile:write(log_tostring(...).."\n");
    logFile:flush();
end


local sec_list      = {
    {'SPBFUT', 'MMU6'},
    {'SPBFUT', 'SiU6'},
    {'SPBFUT', 'RIU6'},
    {'SPBFUT', 'USDRUBF'},
    {'SPBFUT', 'CNYRUBF'},
    {'TQBR', 'SBER'},
    {'TQBR', 'GAZP'}
}

local rev_lis = {}
for i = 1, #sec_list do
    rev_lis[sec_list[i][2]] = i
end

local sleep         = _G.sleep
local isRun         = true

local t_id          = nil

-- local SeaGreen      = 12713921  --  RGB(193, 255, 193) нежно-зеленый
-- local RosyBrown     = 12698111  --  RGB(255, 193, 193) нежно-розовый
-- local GetCell       = _G.GetCell
-- local Highlight     = _G.Highlight
local SetCell           = _G.SetCell
local getParamEx        = _G.getParamEx
local getInfoParam      = _G.getInfoParam
local getQuoteLevel2    = _G.getQuoteLevel2
local IsWindowClosed    = _G.IsWindowClosed
local message           = _G.message
local table_sremove     = _G.table.sremove
local queue             = {}
local get_dom           = {}

function _G.OnParam(class_code,  sec_code)
    local s = os.clock()
    if t_id and rev_lis[sec_code] then
        log('Enter OnParam', class_code,  sec_code)
        local last_price = tonumber((getParamEx(class_code,  sec_code, 'LAST') or {}).param_value) or nil
        local res = {}
        res.last_time  = tonumber((getParamEx(class_code,  sec_code, 'TIME') or {}).param_value) or 0
        if res.last_time == 0 then return end
        res.last_price = last_price
        if not res.last_price then return end
        local bid_depth  = tonumber((getParamEx(class_code,  sec_code, 'BIDDEPTHT') or {}).param_value) or 0
        res.best_bid   = bid_depth > 0 and tonumber((getParamEx(class_code,  sec_code, 'BID') or {}).param_value) or nil
        local ask_depth  = tonumber((getParamEx(class_code,  sec_code, 'OFFERDEPTHT') or {}).param_value) or 0
        res.best_ask   = ask_depth > 0 and tonumber((getParamEx(class_code,  sec_code, 'OFFER') or {}).param_value) or nil
        res.last_rec   = tonumber((tostring(getInfoParam('LASTRECORDTIME') or ''):gsub(':', ''))) or 0
        res.local_time = (tonumber((tostring(getInfoParam('LOCALTIME') or ''):gsub(':', ''))) or 0)
        res.time_diff  = math.abs(res.local_time - res.last_rec) + 10

        queue[#queue+1] = {class_code,  sec_code, last_price}
        log('Exit OnParam', os.clock() - s, class_code,  sec_code, res.last_rec, last_price)
        log('---------------------------------------------------------------------------')
    end
end

function _G.OnQuote(class_code,  sec_code)
    local s = os.clock()
    if t_id and rev_lis[sec_code] and not get_dom[sec_code] then
        log('Enter OnQuote', class_code,  sec_code)
        get_dom[sec_code] = {class_code,  sec_code}
        log('Exit OnQuote', os.clock() - s, class_code,  sec_code)
        log('---------------------------------------------------------------------------')
   end
end

local function CreateTable()

    t_id = _G.AllocTable()

    _G.AddColumn(t_id, 0, "sec", true, _G.QTABLE_STRING_TYPE, 15)
    _G.AddColumn(t_id, 1, "price", true, _G.QTABLE_DOUBLE_TYPE, 15)
    _G.AddColumn(t_id, 2, "bid", true, _G.QTABLE_DOUBLE_TYPE, 15)
    _G.AddColumn(t_id, 3, "ask", true, _G.QTABLE_DOUBLE_TYPE, 15)
    _G.AddColumn(t_id, 4, "edit", true, _G.QTABLE_DOUBLE_TYPE, 15)
    _G.CreateWindow(t_id)
    _G.SetWindowPos(t_id, 90, 120, 470, 300)
    for i = 1, #sec_list do
        _G.InsertRow(t_id, i)
        SetCell(t_id, i, 0, sec_list[i][2])
    end
end

local function event_callback(_, msg, par1, par2)
    log('Enter TableNotificationCallback')
    if (msg == _G.QTABLE_CLOSE) then
        isRun = false
    end
    if msg == _G.QTABLE_CHAR then
        SetCell(t_id, par1, 4, tostring(par2), par2)
    end
    log('Exit TableNotificationCallback')
    log('---------------------------------------------------------------------------')
end

local function process_queue()
    if #queue == 0 then return end
    while #queue > 0 do
        local last_price = queue[1][3]
        -- local lp = GetCell(t_id, 1, 0).value or last_price
        -- if lp < last_price then
        --     Highlight(t_id, 1, 0, SeaGreen, 0, 500)
        -- elseif lp > last_price then
        --     Highlight(t_id, 1, 0, RosyBrown, 0, 500)
        -- end
        SetCell(t_id, rev_lis[queue[1][2]], 1, tostring(last_price), last_price)
        table_sremove(queue, 1)
    end
end

local function GetQuotes(class_code, sec_code)

    local q             = getQuoteLevel2(class_code, sec_code)
    if not q then return end

    local qbid          = q["bid"]
    local qask          = q["offer"]
    if not qbid and not qask then
        return
    end

    local best_bid = tonumber(qbid[#qbid]["price"])
    local best_ask = tonumber(qask[1]["price"])

    SetCell(t_id, rev_lis[sec_code], 2, tostring(best_bid), best_bid)
    SetCell(t_id, rev_lis[sec_code], 3, tostring(best_ask), best_ask)
    get_dom[sec_code] = nil

end

function _G.OnInit()
    CreateTable()
    _G.SetTableNotificationCallback(t_id, event_callback)
end

function _G.main()

    for i = 1, #sec_list do
        if not _G.Subscribe_Level_II_Quotes(sec_list[i][1], sec_list[i][2]) then
            return message('Не удалось подписаться на получение данных стакана по инструменту '..tostring(sec_list[i][1])..'|'..tostring(sec_list[i][2]))
        end
    end

    logFile = io.open(path.."\\load_test.txt", "w")

    local lt = os.time()

    while isRun do
        local s = os.clock()
        log('Enter main loop', os.date())
      IsWindowClosed(t_id)
        local ct = os.time()
        local u
        -- if ct-lt >= 2 then
            -- for i = 1, #sec_list do
                -- queue[#queue+1] = {sec_list[i][1], sec_list[i][2], tonumber(getParamEx(sec_list[i][1], sec_list[i][2], 'LAST').param_value)}
                -- get_dom[sec_list[i][2]] = {sec_list[i][1], sec_list[i][2]}
                -- u = true
            -- end
            -- lt = ct
        -- end
        process_queue()
        for i = 1, #sec_list do
            if get_dom[sec_list[i][2]] then
                GetQuotes(sec_list[i][1], sec_list[i][2])
            end
        end
        bl1.func1()
        bl2.func100()
        bl3.func200()
        bl4.func300()
        log('Exit main loop', os.clock()-s, u and 'update' or '')
        log('---------------------------------------------------------------------------')
        sleep(60)
    end
end

function _G.OnStop()
    isRun = false
    if t_id and not IsWindowClosed(t_id) then
        _G.DestroyTable(t_id)
    end
end

local function log(...)
    PrintDbgStr(log_tostring(...))
end

res.last_rec    = 0  ---   tonumber((tostring(getInfoParam('LASTRECORDTIME') or ''):gsub(':', ''))) or 0
res.local_time = 0 --- (tonumber((tostring(getInfoParam('LOCALTIME') or ''):gsub(':', ''))) or 0)

----   Функции работы с очередями --
--- При использовании между потоком колбеков и потоком main очереди потокобезопасные. ---
--- Создать очередь 
function QueueNew()
   return  {first = 1, last = 0 }
end
---  Записать в очередь --
function QueuePush(self, v)
   if v == nil then error('!!! Ошибка. Параметр v функции QueuePush nil') end
   local last = self.last + 1 
   self[last] = v
   self.last = last
   return last - self.first + 1    -- количество элементов в очереди ---
end 
---  Читать очередь  --
function QueuePop(self)
   local  first =  self.first
   if  first > self.last then return nil   end 
   local v, v1  =  self[first], self[first + 1]
   self.first = first + 1 
   self[first] =  nil 
   v1 = type (v1) == 'string' and #v1 or 0
   return  v, v1   -- v1 -длина следующего элемента (если строка) ---
end
  
-- Текущий размер очереди ---
function QueueSize(self)
   return self.last - self.first + 1 
end 

local path = _G.getScriptPath()
package.path = path.."/?.lua;"

local bl1 = require('big_lib')
local bl2 = require('big_lib2')
local bl3 = require('big_lib3')
local bl4 = require('big_lib4')

local id = 'script 1:'
local logFile

local function log_tostring(...)
    local n = select('#', ...)
    if n == 1 then
    return tostring(select(1, ...))
    end
    local t = {}
    t[#t + 1] = id
    for i = 1, n do
    t[#t + 1] = tostring((select(i, ...)))
    end
    return table.concat(t, " ")
end

local function log(...)

    -- Пишем в отладочные сообщения, вместо лога
    PrintDbgStr(log_tostring(...))
    -- Пишем в отладочные сообщения, вместо лога

    -- if logFile==nil then return end
    -- logFile:write(log_tostring(...).."\n");
    -- logFile:flush();
end


local sec_list      = {
    {'SPBFUT', 'MMU6'},
    {'SPBFUT', 'SiU6'},
    {'SPBFUT', 'RIU6'},
    {'SPBFUT', 'USDRUBF'},
    {'SPBFUT', 'CNYRUBF'},
    {'TQBR', 'SBER'},
    {'TQBR', 'GAZP'}
}

local last_data = {}


local rev_lis = {}
for i = 1, #sec_list do
    rev_lis[sec_list[i][2]] = i
    last_data[sec_list[i][2]] = {}
end

local sleep         = _G.sleep
local isRun         = true

local t_id          = nil

-- local SeaGreen      = 12713921  --  RGB(193, 255, 193) нежно-зеленый
-- local RosyBrown     = 12698111  --  RGB(255, 193, 193) нежно-розовый
-- local GetCell       = _G.GetCell
-- local Highlight     = _G.Highlight
local SetCell           = _G.SetCell
local getParamEx        = _G.getParamEx
local getInfoParam      = _G.getInfoParam
local getQuoteLevel2    = _G.getQuoteLevel2
local IsWindowClosed    = _G.IsWindowClosed
local DestroyTable      = _G.DestroyTable
local message           = _G.message
-- local table_sremove     = _G.table.sremove

local Queue = {}
Queue.__index = Queue

function Queue.new()
   return setmetatable({first = 1, last = 0 }, Queue)
end
---  Записать в очередь --
function Queue:push(v)
   if v == nil then error('!!! Ошибка. Параметр v функции QueuePush nil') end
   local last = self.last + 1
   self[last] = v
   self.last = last
   return last - self.first + 1    -- количество элементов в очереди ---
end
---  Читать очередь  --
function Queue:pop()
   local  first =  self.first
   if  first > self.last then return nil   end
   local v, v1  =  self[first], self[first + 1]
   self.first = first + 1
   self[first] =  nil
   v1 = type (v1) == 'string' and #v1 or 0
   return  v, v1   -- v1 -длина следующего элемента (если строка) ---
end

-- Текущий размер очереди ---
function Queue:size()
   return self.last - self.first + 1
end


local queue             = Queue.new()
local get_dom           = {}

function _G.OnParam(class_code,  sec_code)
    local s = os.clock()
    if t_id and rev_lis[sec_code] then
        -- log('Enter OnParam', class_code,  sec_code)
        local last_price = tonumber((getParamEx(class_code,  sec_code, 'LAST') or {}).param_value) or nil
      -- Записываем в очередь только если цена изменилась
        if last_data[sec_code][1] == last_price then return end
        local res = {}
        res.last_time  = tonumber((getParamEx(class_code,  sec_code, 'TIME') or {}).param_value) or 0
        if res.last_time == 0 then return end
        res.last_price = last_price
        if not res.last_price then return end
        local bid_depth  = tonumber((getParamEx(class_code,  sec_code, 'BIDDEPTHT') or {}).param_value) or 0
        res.best_bid   = bid_depth > 0 and tonumber((getParamEx(class_code,  sec_code, 'BID') or {}).param_value) or nil
        local ask_depth  = tonumber((getParamEx(class_code,  sec_code, 'OFFERDEPTHT') or {}).param_value) or 0
        res.best_ask   = ask_depth > 0 and tonumber((getParamEx(class_code,  sec_code, 'OFFER') or {}).param_value) or nil
        res.last_rec   = tonumber((tostring(getInfoParam('LASTRECORDTIME') or ''):gsub(':', ''))) or 0
        res.local_time = (tonumber((tostring(getInfoParam('LOCALTIME') or ''):gsub(':', ''))) or 0)
        res.time_diff  = math.abs(res.local_time - res.last_rec) + 10
        last_data[sec_code][1] = last_price
        queue:push{class_code,  sec_code, last_price}
        -- log('Exit OnParam', os.clock() - s, class_code,  sec_code, res.last_rec, last_price)
        -- log('---------------------------------------------------------------------------')
    end
end

function _G.OnQuote(class_code,  sec_code)
    local s = os.clock()
    if t_id and rev_lis[sec_code] and not get_dom[sec_code] then
        -- log('Enter OnQuote', class_code,  sec_code)
        get_dom[sec_code] = {class_code,  sec_code}
        -- log('Exit OnQuote', os.clock() - s, class_code,  sec_code)
        -- log('---------------------------------------------------------------------------')
   end
end

local function event_callback(_, msg, par1, par2)
    -- log('Enter TableNotificationCallback', msg, par1, par2)
    if (msg == _G.QTABLE_CLOSE) then
        isRun = false
    end
    if msg == _G.QTABLE_CHAR then
        SetCell(t_id, par1, 4, tostring(par2), par2)
    end
    -- log('Exit TableNotificationCallback', msg, par1, par2)
    -- log('---------------------------------------------------------------------------')
end

local function CreateTable()

    t_id = _G.AllocTable()

    _G.AddColumn(t_id, 0, "sec", true, _G.QTABLE_STRING_TYPE, 15)
    _G.AddColumn(t_id, 1, "price", true, _G.QTABLE_DOUBLE_TYPE, 15)
    _G.AddColumn(t_id, 2, "bid", true, _G.QTABLE_DOUBLE_TYPE, 15)
    _G.AddColumn(t_id, 3, "ask", true, _G.QTABLE_DOUBLE_TYPE, 15)
    _G.AddColumn(t_id, 4, "edit", true, _G.QTABLE_DOUBLE_TYPE, 15)
    _G.CreateWindow(t_id)
    _G.SetWindowPos(t_id, 90, 120, 470, 300)
    for i = 1, #sec_list do
        _G.InsertRow(t_id, i)
        SetCell(t_id, i, 0, sec_list[i][2])
    end
    _G.SetTableNotificationCallback(t_id, event_callback)
end

local function process_queue()
    local n = 0
    local res = queue:pop()
    while res do
        n = n + 1
        local last_price = res[3]
        -- local lp = GetCell(t_id, 1, 0).value or last_price
        -- if lp < last_price then
        --     Highlight(t_id, 1, 0, SeaGreen, 0, 500)
        -- elseif lp > last_price then
        --     Highlight(t_id, 1, 0, RosyBrown, 0, 500)
        -- end
        SetCell(t_id, rev_lis[res[2]], 1, tostring(last_price), last_price)
        -- log(' --- set pop value',  n, rev_lis[res[2]], last_price)
        res = queue:pop()
    end
    return n
end

local function GetQuotes(class_code, sec_code)

    local q             = getQuoteLevel2(class_code, sec_code)
    if not q then return end

    local qbid          = q["bid"]
    local qask          = q["offer"]
    if not qbid and not qask then
        return
    end

    local best_bid = tonumber(qbid[#qbid]["price"])
    local best_ask = tonumber(qask[1]["price"])

    if last_data[sec_code][2] ~= best_bid then
        SetCell(t_id, rev_lis[sec_code], 2, tostring(best_bid), best_bid)
        last_data[sec_code][2] = best_bid
    end
    if last_data[sec_code][3] ~= best_ask then
        SetCell(t_id, rev_lis[sec_code], 3, tostring(best_ask), best_ask)
        last_data[sec_code][3] = best_ask
    end
    get_dom[sec_code] = nil

end

function _G.main()

    for i = 1, #sec_list do
        if not _G.Subscribe_Level_II_Quotes(sec_list[i][1], sec_list[i][2]) then
            return message('Не удалось подписаться на получение данных стакана по инструменту '..tostring(sec_list[i][1])..'|'..tostring(sec_list[i][2]))
        end
    end

    CreateTable()

    -- logFile = io.open(path.."\\load_test.txt", "w")

    local lt = os.time()
    local wnd_kill_interval = 120

    while isRun do

        local cwt = os.time()
        if cwt - lt > wnd_kill_interval then
            lt = cwt
            DestroyTable(t_id)
            CreateTable()
        end

        -- тест скорости локальной очереди
            -- local list = Queue.new()
            -- for i = 1, 10000 do
            --     list:push(i)
            -- end
            -- local st = os.clock()
            -- while list:pop() do end
            -- log('process 10000 for time', os.clock() - st)
        -- тест скорости локальной очереди

        local s = os.clock()
        log('Enter main loop', os.date())
      IsWindowClosed(t_id)
        local ct = os.clock()
        local n = process_queue()
        local qt = os.clock() - ct
        ct = os.clock()
        local qn = 0
        for i = 1, #sec_list do
            if get_dom[sec_list[i][2]] then
                qn = qn + 1
                GetQuotes(sec_list[i][1], sec_list[i][2])
            end
        end
        local dt = os.clock() - ct
        bl1.func1()
        bl2.func100()
        bl3.func200()
        bl4.func300()
        log('Exit main loop', os.clock()-s, 'in queue', n, 'queue time', qt, 'dom time', dt, 'for', qn)
        log('---------------------------------------------------------------------------')
        sleep(60)
    end
end

function _G.OnStop()
    isRun = false
    if t_id and not IsWindowClosed(t_id) then
        _G.DestroyTable(t_id)
    end
end

-- ====================================================================
-- ИСПРАВЛЕНО (ИЗЛОМ 2): ЧИСТЫЙ НАЛИВ ИЗ МОДУЛЯ БЕЗ ДУБЛИРОВАНИЯ ПОЛЕЙ
-- Все флаги, заголовки и REQ_PARAMS_REGISTRY уже запечатаны в MEO_Config.lua!
-- ====================================================================
_G.MEO_Config = require("MEO_Config").init()
local c = _G.MEO_Config

-- Прописываем только динамический маркер старта
c.PLATFORM_START_TIMESTAMP = os.time() 

-- ====================================================================
-- ГЛOБAЛЬНЫE КOЛЛБЭКИ ТEРМИНAЛA QUIK API С МЬЮТЕКС-ЭКРАНИРОВАНИЕМ
-- ====================================================================
function OnAllTrade(trade)
    if not Robot or not c.is_run or not c.IS_WARMED_UP or Robot.Is_Inside_HotPath then return end
    if type(Robot.ProcessAllTradeEvent) == "function" then Robot:ProcessAllTradeEvent(trade) end
end

function OnQuote(class_code, sec_code)
    if not Robot or not c.is_run or not c.IS_WARMED_UP or Robot.Is_Inside_HotPath then return end
    if Robot.BookBridge and type(Robot.BookBridge.ProcessQuoteEvent) == "function" then 
        Robot.BookBridge:ProcessQuoteEvent(class_code, sec_code) 
    end
end

function OnParam(class_code, sec_code)
    if not Robot or not c.is_run or not c.IS_WARMED_UP or Robot.Is_Inside_HotPath then return end
    if Robot.ProcessParamEvent and type(Robot.ProcessParamEvent) == "function" then 
        Robot:ProcessParamEvent(class_code, sec_code) 
    end
end

function OnFuturesClientHolding(fut_pos)
    if not Robot or not c.is_run or not c.IS_WARMED_UP or Robot.Is_Inside_HotPath then return end
    if Robot.Ledger and type(Robot.Ledger.IncorporateExchangeHolding) == "function" then 
        Robot.Ledger:IncorporateExchangeHolding(fut_pos) 
    end
end

function OnFuturesLimitChange(fut_limit)
    if not Robot or not c.is_run or not c.IS_WARMED_UP or Robot.Is_Inside_HotPath then return end
    if Robot.ProcessFuturesLimitChangeEvent and type(Robot.ProcessFuturesLimitChangeEvent) == "function" then 
        Robot:ProcessFuturesLimitChangeEvent(fut_limit) 
    end
end

function OnTrade(trade)
    if not Robot or not c.is_run or not c.IS_WARMED_UP or Robot.Is_Inside_HotPath then return end
    if Robot.Tracker and type(Robot.Tracker.ProcessTradeEvent) == "function" then 
        Robot.Tracker:ProcessTradeEvent(trade) 
    end
end

function OnTransReply(reply)
    if not Robot or not c.is_run or not c.IS_WARMED_UP then return end
    if Robot.Tracker and type(Robot.Tracker.RegisterTransReply) == "function" then 
        Robot.Tracker:RegisterTransReply(reply) 
    end
end

function OnOrder(order)
    if not Robot or not c.is_run or not c.IS_WARMED_UP then return end
    if Robot.Tracker and type(Robot.Tracker.RegisterOrderEvent) == "function" then 
        Robot.Tracker:RegisterOrderEvent(order) 
    end
end

function OnStop()
    c.is_run = false
    if Robot and type(Robot.DestroyAndUnsubscribe) == "function" then Robot:DestroyAndUnsubscribe() end
    message("MEO OS: Core supervisor engine terminated securely. All local subscriptions cleared.", 1)
    return 1000 
end

-- ====================================================================
-- ГЛАВНАЯ ТОЧКА ВХОДА ИЗОХРОННОГО РАНТАЙМА (КОНТУР А)
-- ====================================================================
function main()

    if not c.ACCOUNT or c.ACCOUNT == "" or not c.CLIENT_CODE or c.CLIENT_CODE == "" then
        c.is_run = false
        message("MEO SUPERVISOR FATAL: Ключи счета не обнаружены в ОЗУ таблицы MEO_Config.lua!", 3)
        return
    end

    package.loaded["MEO_PreFlight_Validator"] = nil
    local PreFlightLauncher = require("MEO_PreFlight_Validator")

    -- Аппаратный Handshake поднимает, прогревает и возвращает готовый объект Robot
    _G.Robot = PreFlightLauncher.ExecuteFullHandshake(c)

    if not _G.Robot then
        message("MEO SUPERVISOR FATAL: Предполётная подготовка прервана отказом шлюзов!", 3)
        return
    end

    local last_known_size = c.BAR_CACHE_IDX
    local TT = GetMilliseconds()

    while c.is_run do
        local cur_size = _G.Robot.ds:Size()
        if cur_size > 0 then
            if cur_size > last_known_size then
                last_known_size = cur_size
                c.BAR_CACHE_IDX = cur_size
                _G.Robot:ExecuteQuantumClosure(_G.Robot.ds, cur_size)
            end
        end
        
        if _G.Robot.ProcessLearningQueue then _G.Robot:ProcessLearningQueue() end
        if _G.Robot.TriggerUIRender then _G.Robot:TriggerUIRender() end
        
        local current_work_time = GetMilliseconds() - TT
        c.LAST_EXECUTION_LAG = current_work_time
        local calculated_sleep = 200 - current_work_time
        if calculated_sleep <= 0 then calculated_sleep = 1 end
        sleep(calculated_sleep)
        TT = GetMilliseconds()
    end
end