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

local class, sec = "CLASS", "SEC"
local alltrade = {price = 1, qty = 1, class_code = "CLASS", sec_code = "SEC"}

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

local Volume = {}
local function Claster(alltrade)
  if alltrade.sec_code == sec and alltrade.class_code == class then
    Volume[alltrade.price] = (Volume[alltrade.price] or 0) + alltrade.qty
  end
end

local N
function OnInit()
  N = 100000000
end

function OnAllTrade()
  run = false
end

function OnParam()
  run = false
end

function main()
  for i = 0, N-1 do
    Claster(alltrade)
    if not run then break end
  end
  message(tostring(run) .. '\n' .. Volume[alltrade.price])
end

Queue = {
  new = function (self)
    return setmetatable({first = 1, last = 0}, {__index = self})
  end,
  push = function (self, v)
    local last = self.last + 1
    self[last] = v
    self.last = last
    return last
  end,
  pop = function (self)
    local first = self.first
    if first > self.last then return nil end
    local v = self[first]
    self.first = first + 1
    self[first] = nil
    return v
  end,
  size = function (self)
    return self.last - self.first + 1
  end
}

local OnAllTra des = Queue:new()
local function f(alltrade)
  ...
  OnAllTrades:push(alltrade)
  ...
end

function OnAllTrade(alltrade)
  ...  -- Во время ошибки параллельный поток находился где-то здесь
  f(alltrade)
end

local run = true
function main()
  while run do
    ...
    if OnAllTrades:size() > 0 then
     local alltrade = OnAllTrades:pop()  -- Тут ошибка "attempt to call a nil value (method 'pop')"
     ...
    end
  end
end

local OnAllTra des = Queue:new()

local class = "TQBR"
local sec = "SBER"

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

function OnConnected()
  message("OnConnected")
end

function main()
  while isConnected() ~= 1 and run do sleep(1) end
  local ds, err = CreateDataSource(class, sec, INTERVAL_M1)
  if ds then
    message("OK")
    ds:SetEmptyCallback()
  else
    message(err, 3)
    return
  end
  for i = 1, 1000 do
    sleep(600)
    if not run then break end
  end
  message(string.format("size: %u", ds:Size()))
  ds:Close()
end

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

function main()
  while isConnected() ~= 1 and run do sleep(1) end
  local n = 0
  local m = 0
  local sources = {}
  local list = ""
  for sec in getClassSecurities(class):gmatch("([^,]+)") do
    if not run then break end
    local ds, err = CreateDataSource(class, sec, INTERVAL_M1)
    if ds then
      ds:SetEmptyCallback()
      n = n + 1
      sources[n] = {ds, sec}
      list = list .. sec .. ","
    else
      message(string.format("Failed to create data source: %s\n%s %s", err, class, sec))
      m = m + 1
    end
  end
  message(string.format("OK: %u, ERROR: %u\n%s", n, m, list))
  while n > 0 and run do
    for i = n, 1, -1 do
      local source = sources[i]
      local size = source[1]:Size()
      if size > 0 then
        n = n - 1
        message(string.format("%s: %u\n%u", source[2], size, n))
        source[1]:Close()
        table.remove(sources, i)
      end
    end
    sleep(500)
  end
end