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

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

local id = 'script1'
local logFile

function _G.OnInit(script_path)
   id = ((script_path:match("[^/\\]+$")):gsub('.lua', ''))
end

local function log_tostring(...)
  local args = table.pack(...)
  if args.n == 1 then
    return tostring(args[1])
  end
  for i = 1, args.n do
    args[i] = tostring(args[i])
  end
  return table.concat(args, " ", 1, args.n)
end

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

local sleep         = _G.sleep
local message       = _G.message
local isRun         = true

local last_rec, last_time, time_diff
local start_rec = tonumber(getInfoParam('LASTRECORD') or '') or 0

local q = 0
local t = os.time()
local start

function _G.OnParam(class_code,  sec_code)
   if q == 0 then t = os.time() end
   q = q + 1
   local last_price = tonumber((getParamEx(class_code,  sec_code, 'LAST') or {}).param_value)
   -- PrintDbgStr(log_tostring('OnParam', q, class_code,  sec_code, 'last_price', last_price))
end

local function log_stat()

   local end_rec   = tonumber(getInfoParam('LASTRECORD') or '') or 0
   local loaded   = end_rec - start_rec
   t = os.time() - t
   local str = log_tostring(id, ': done', ', processed callbacks: ', q, ', in: ', t, 'sec', ', avg: ', q == 0 and '---' or t/q)
   message(str)
   local str1 = log_tostring(id, ': start_rec: ', start_rec, ', end_rec: ', end_rec, ', loaded records: ', loaded, ', avg: ', loaded == 0 and '---' or t/loaded)
   message(str1)
   if io.type(logFile) == 'file' then
       log(str)
       log(str1)
      logFile:close()
   end
end


function _G.main()

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

    while isRun do
        sleep(10)
    end
end

function _G.OnDisconnected()
   message('OnDisconnected, current_rec: '..tostring(tonumber(getInfoParam('LASTRECORD') or '') or 0))
   q = 0
   t = os.time()
end

function _G.OnConnected(flag)
   if flag then
      start_rec   = tonumber(getInfoParam('LASTRECORD') or '') or 0
      message('OnConnected, start_rec: '..tostring(start_rec))
      q = 0
      t = os.time()
      start = true
   end
end

function _G.OnStop()
    isRun = false
   log_stat()
end

    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

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 = 'script3'
local logFile

local function log_tostring(...)
  local args = table.pack(...)
  if args.n == 1 then
    return tostring(args[1])
  end
  for i = 1, args.n do
    args[i] = tostring(args[i])
  end
  return table.concat(args, " ", 1, args.n)
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 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 IsWindowClosed    = _G.IsWindowClosed

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 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(id, ' --- set pop value',  n, rev_lis[res[2]], last_price)
        res = queue:pop()
    end
    return n
end

local function GetPrice(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}
end

local function event_callback(_, msg, par1, par2)
    if (msg == _G.QTABLE_CLOSE) then
        isRun = false
    end
    if msg == _G.QTABLE_CHAR then
        SetCell(t_id, par1, 2, tostring(par2), par2)
    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, "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

function _G.OnParam(class_code,  sec_code)
    local last_price = tonumber((getParamEx(class_code,  sec_code, 'LAST') or {}).param_value) or nil

   -- if rev_lis[sec_code] then
      -- GetPrice(class_code,  sec_code)
   -- end
end

local last_rec, last_time, time_diff


function _G.main()

    CreateTable()

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

    local lt = 0
    local req_int = 1

    while isRun do

        local cwt = os.time()
        if cwt - lt > req_int then
            lt = cwt
            for i = 1, #sec_list do
                GetPrice(sec_list[i][1], sec_list[i][2])
            end
        end

   last_rec   = tonumber((tostring(getInfoParam('LASTRECORDTIME') or ''):gsub(':', ''))) or 0
   local_time = (tonumber((tostring(getInfoParam('LOCALTIME') or ''):gsub(':', ''))) or 0)
   time_diff  = math.abs(local_time - last_rec) + 10

        -- log(id, 'Enter main loop')
   IsWindowClosed(t_id)
        local n = process_queue()
        bl1.func1()
        bl2.func100()
        bl3.func200()
        bl4.func300()
        -- log(id, 'Exit main loop', 'in queue', n)
        -- 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 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 = 'script1'
local logFile

local function log_tostring(...)
  local args = table.pack(...)
  if args.n == 1 then
    return tostring(args[1])
  end
  for i = 1, args.n do
    args[i] = tostring(args[i])
  end
  return table.concat(args, " ", 1, args.n)
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 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 IsWindowClosed    = _G.IsWindowClosed

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 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(id, ' --- set pop value',  n, rev_lis[res[2]], last_price)
        res = queue:pop()
    end
    return n
end

local function GetPrice(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}
end

local function event_callback(_, msg, par1, par2)
    if (msg == _G.QTABLE_CLOSE) then
        isRun = false
    end
    if msg == _G.QTABLE_CHAR then
        SetCell(t_id, par1, 2, tostring(par2), par2)
    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, "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

function _G.main()

    CreateTable()

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

    local lt = 0
    local req_int = 1

    while isRun do

        local cwt = os.time()
        if cwt - lt > req_int then
            lt = cwt
            for i = 1, #sec_list do
                GetPrice(sec_list[i][1], sec_list[i][2])
            end
        end

        -- local s = os.clock()
        -- log(id, 'Enter main loop', os.date())
      IsWindowClosed(t_id)
        local n = process_queue()
        bl1.func1()
        bl2.func100()
        bl3.func200()
        bl4.func300()
        -- log(id, 'Exit main loop', os.clock()-s, 'in queue', n)
        -- 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 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

        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)