while f do
  r();      -- раз в секунду запускаем утилиту опроса
  sleep(1000);   -- текущих данных и принятия решений по ним
 end;

function r()   -- мелкий обработчик прерывания по таймеру
 for i=0,N-1 do -- цикл по тикерам (прорисовка таблицы)
  s=a[i][2];   -- предыдущее и последнее значение курса
  a[i][2]=tonumber(getParamEx(a[i][1][0],a[i][0],"LAST").param_value);
...

json = require("lib.json")
socket = require("lib.socket")
cfg = require("config")

function string.starts(String,Start)
   return string.sub(String,1,string.len(Start))==Start
end

function hasOption (tab, val)
    for index, value in ipairs(tab) do
        if string.starts(val, value) then
            return true
        end
    end

    return false
end

function OnInit(script) 
   isRun = true
   connected = false
   InstrumentsQueue = {}
end

function OnParam(class_code, sec_code)
   if cfg.classes:find(class_code) ~= nil then
      if (class_code == "SPBOPT" and hasOption(cfg.optionFilter, sec_code) == false) then
         return
      end

      local data = {}
      data["market"] = getParamEx(class_code, sec_code, "CLASS_CODE")
      data["ticker"] = getParamEx(class_code, sec_code, "CODE")
                -- кусь --
      table.sinsert(InstrumentsQueue, data)
   end
end

function OnStop()
   isRun = false
   client:close()
   return 3000
end

function connect()
   if connected == false then
      client = socket.connect(cfg.server.host, cfg.server.port)
      if client == nil then
         message("Error connecting to socket server")
         sleep(5000)
      else
         connected = true
         message("Connected to socket server")
      end
   end
end


function main()
   while isRun do 
   connect()
   if #InstrumentsQueue > 0 and connected then
      local data = InstrumentsQueue[1]
      local jsonData = json.encode({type = "instrument", value = data})
      local status, msg = client:send(jsonData .. "\r\n")
      
      if status ~= nil then
         table.sremove(InstrumentsQueue, 1)
      else
         message("Error sending data to socket server #" .. msg)
         if msg == "closed" then
            message("Disconnected from socket server")
            client:close()
            connected = false
         end
      end
   else
      sleep(50)
   end
   end
end

local paramTable = {}
  table.ssort({ 0, 1 }, function(a, b)  
  -- Тут делаем нужные операции, которые, по идее, должны быть выполнены атомарно
  paramTable["bid"] =  GetParamEx(аргументы для получения bid).param_value
  paramTable["offer"] =  GetParamEx(аргументы для получения offer).param_value
  -- Далее аналогично
return true
end)