--
-- Реализация очереди из функций и их исполнения.
--

local Executor = {}

--- Конструктор.
-- @param self объект
local function new(self)
    local queue = {
        head = 1,
        tail = 0
    }
    setmetatable(queue, self)
    self.__index = self
    return queue
end

Executor.new = new

--- Поместить функцию в очередь на выполнение.
-- @param self объект
-- @param f функция
local function submit(self, f)
    if type(f) == "function" then
        self[self.tail + 1] = f
        self.tail = self.tail + 1
    end
end

Executor.submit = submit

--- Получить очередную функцию из очереди.
-- @param self объект
-- @return функция
local function get(self)
    if self.head > self.tail then
        return nil
    else
        local f = self[self.head]
        self[self.head] = nil
        self.head = self.head + 1
        return f
    end
end

Executor.get = get

--- Выполнять функции из очереди либо пока они там есть, либо пока не будет выполнено указанное количество функций.
-- @param self объект
-- @param max максимальное количество исполняемых за один раз функций
local function execute(self, max)
    max = max or 1000000
    while max > 0 do
        local f = self:get()
        if f == nil then
            return
        else
            f()
            max = max - 1
        end
    end
end

Executor.execute = execute

return Executor

local tradeCounters = {} -- таблица[secCode], содержащая количество обезличенных сделок по каждому инструменту

function OnAllTrade(t)
    executor:submit(function()
            tradeCounters[t.sec_code] = (tradeCounters[t.sec_code] or 0) + 1
    end)
end

while not interrupted do
    ....
    executor:execute()
    ....
end

data = {};

function update_ui()
   Clear(table_id)
   for i,v = in ipairs(data) do
      InsertRow(table_id, ...)
   end
end

function calculate_data_item(v)
   -- Calculate new value based on v
   -- Long, thread unsafe operation in real code, depends on other data[..] items
   -- Adding 1 here only as example
   return v + 1;
end

function update_all_data_items()
   for i,v = in ipairs(data) do
      data[i] = calculate_data_item(v);
   end
end

function main()
   -- Request level 2 quotes for each security
   -- Init table, columns ... 
   while true do
      -- START atomic operation on data array
      update_all_data_items()
      update_ui()
      -- End atomic operation
      sleep(1000)   
   end
end

function OnQuote(p1, p2)
   -- START atomic operation on data[p2]
   data[p2] = calculate_data_item(...)
   update_ui()
   -- End atomic operation on data[p2]
end