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

D:\QUIK_BROKER1
D:\QUIK_BROKER2
D:\QUIK_BROKER3

--
-- Подгонка размеров окна.
--

local interrupted = false

function OnStop()
    interrupted = true
end

function main()
    local tId = AllocTable()
    CreateWindow(tId)

    local topPrev, leftPrev, bottomPrev, rightPrev = 0, 0, 0, 0
    while not interrupted do
        if IsWindowClosed(tId) then
            break
        end
        local top, left, bottom, right = GetWindowRect(tId)
        if top == nil or left == nil or bottom == nil or right == nil then
            break
        end
        if topPrev ~= top or leftPrev ~= left or bottomPrev ~= bottom or rightPrev ~= right then
            SetWindowCaption(tId, "x=" .. tostring(left)
                    .. ",y=" .. tostring(top)
                    .. ",dx=" .. tostring(right - left)
                    .. ",dy=" .. tostring(bottom - top))
            topPrev = top
            leftPrev = left
            bottomPrev = bottom
            rightPrev = right
        else
            sleep(50)
        end
    end
end

local ds = CreateDataSource(classCode, secCode, INTERVAL_M5)

local size = ds:Size()

ExecuteCallback(function() 
  -- обращение к данным ds, которое будет произведено в потоке коллбэков
end)

SwingUtilities.invokeLater(Runnable doRun)

local function init(ds, timeout)
  local deadline = os.time() + timeout
  while os.time() < deadline do
    if ds:Size() > 0 then
      return true
    end
    sleep(100)
  end
  return false
end

del /F /Q acnt.dat
del /F /Q alerts.dat
del /F /Q alltrade.dat
del /F /Q banners.dat
del /F /Q classes.dat
del /F /Q firms.dat
del /F /Q limits.dat
del /F /Q locales.dat
del /F /Q orders.dat
del /F /Q par.dat
del /F /Q portfolio.dat
del /F /Q scripts.dat
del /F /Q search.dat
del /F /Q sec.dat
del /F /Q tmsg.dat
del /F /Q tradermsg.dat
del /F /Q trades.dat
del /F /Q trans.dat
del /F /Q transresult.dat

del /F /Q info.log
del /F /Q portfolio.log

info.exe -clear

value.tbl.bid[indexBid].price

local tbl = value.tbl
local bids = tbl.bid
local price = bids[indexBid].price

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

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

local SELL_FLAG = 1
local BUY_FLAG = 2

function OnAllTrade(allTrade)
    ...
    local buySell = 0
    if bit.band(currTrade.flags, BUY_FLAG) == BUY_FLAG then
        buySell = 1
    elseif bit.band(currTrade.flags, SELL_FLAG) == SELL_FLAG then
        buySell = -1
    end
    ...
end

--
-- Реализация таймера.
--
-- Пример использования:
-- local Timer = require("util.Timer")
-- local timer = Timer:new()
-- timer:setInterval(10)
-- ...
-- if timer:isTimeout() then ...
--

local Timer = {}

--- Конструктор.
-- @param self объект
local function new(self)
    local timer = {
        deadline = os.time()
    }
    setmetatable(timer, self)
    self.__index = self
    return timer
end

Timer.new = new

--- Задать интервал, по прошествии которого считается, что таймер сработал.
-- @param self объект
-- @param duration число секунд, через которое должен сработать таймер.
local function setInterval(self, duration)
    self.deadline = os.time() + duration
end

Timer.setInterval = setInterval

--- Задать момент времени, по прошествии которого считается, что таймер сработал.
-- @param self объект
-- @param date таблица, задающая дату, когда должен сработать таймер.
local function setDate(self, date)
    self.deadline = os.time(date)
end

Timer.setDate = setDate

--- Узнать, через сколько секунд осталось до момента срабатывания таймера.
-- @param self объект
-- @return количество секунд оставшееся до срабатывания таймера или 0, если время срабатывания прошло
local function getSecondsLeft(self)
    return math.max(0, self.deadline - os.time())
end

Timer.getSecondsLeft = getSecondsLeft

--- Узнать, наступил ли момент срабатывания таймера.
-- @param self объект
-- @return true/false
local function isTimeout(self)
    return os.time() >= self.deadline
end

Timer.isTimeout = isTimeout

return Timer

local function printMemoryUsed()
    logger:debug("Memory used: " .. math.ceil(collectgarbage("count") / 1024) .. "M")
end

local function run()
    while not interrupted do
        ...
        if garbageTimer:isTimeout() then
            printMemoryUsed()
            logger:debug("Collecting garbage...")
            collectgarbage()
            printMemoryUsed()
            garbageTimer:setInterval(600)
        end
        ...
    end
end

function main()
    ...
    run()
    ...
end