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

--
-- Реализация таймера.
--
-- Пример использования:
-- 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

2017-06-29 02:50:32.474 [INFO ] Exporting trades...
2017-06-29 02:50:32.927 [ERROR] function: 03F7E360
2017-06-29 02:50:32.927 [INFO ] SHUTDOWN

ждём, пока не будет ds:Size() > 0, периодически засыпая на 100 мс, но не более 15-20 секунд

2017-06-25 20:18:26.086 [ERROR] not enough memory

local Tt = tmpParam.DAYS_TO_MAT_DATE / YearLen --"T-t" время до истечения срока опциона (период опциона);

local rsiFormatted = string.format("RSI=%.1f", rsiValue)

message(os.date("%d.%.m.%Y"), 1)

local function isFuturesFromTable(sec, fut)
    for stockCode, futCode in pairs(fut) do
        if sec == futCode then
            return true
        end
    end
    return false
end

--
-- Реализация индикатора RSI_Simple.
--

Settings = {
    Name = "RSI_Simple",
    period = 14,
    priceType = "Typical", -- Open, High, Low, Close, Volume, Median, Typical, Weighted
    line = {
        { Name = "RSI_Simple", Type = TYPE_LINE, Color = RGB(255, 0, 0), },
    }
}

function Init()
    func = rsiSimple()
    return #Settings.line
end

function OnCalculate(index)
    return func(index, Settings)
end

local function getPrice(i, priceType)
    local s = priceType and string.upper(string.sub(priceType, 1, 1)) or "C"
    if s == "O" then
        return O(i)
    elseif s == "H" then
        return H(i)
    elseif s == "L" then
        return L(i)
    elseif s == "C" then
        return C(i)
    elseif s == "V" then
        return V(i)
    elseif s == "M" then
        return (H(i) + L(i)) / 2
    elseif s == "T" then
        return (H(i) + L(i) + C(i)) / 3
    elseif s == "W" then
        return (O(i) + H(i) + L(i) + C(i)) / 4
    else
        return C(i)
    end
end

function rsiSimple()
    local window = {} -- окно с рядом цен, по которым строится индикатор
    local from = 1 -- индекс начала данных в окне
    local to = 0 -- индекс конца данных в окне (если to < from, данных нет)
    local lastIndex = 0 -- номер свечи, имеющей цены, при последнем вызове OnCalculate()
    local sumUp = 0 -- сумма всех положительных изменений цен за исключением приращения на формирующемся баре
    local sumDn = 0 -- сумма всех отрицательных изменений цен за исключением приращения на формирующемся баре
    local lastIndicatorValue -- значение индикатора при последнем вызове OnCalculate()
    return function(index, settings)
        local period = 14
        local priceType = "Typical"
        if settings then
            period = settings.period or period
            priceType = settings.priceType or priceType
        end
        if index == 1 then
            window = {}
            from = 1
            to = 0
            lastIndex = 0
            sumUp = 0
            sumDn = 0
            lastIndicatorValue = nil
        end
        if CandleExist(index) then
            local currPrice = getPrice(index, priceType)
            if index ~= lastIndex then
                -- Новая свеча
                if to - from + 1 == period + 1 then
                    -- Окно заполнено, т.е. имеет длину period + 1, нужно удалить первый элемент и уменьшить суммы
                    local delta = window[from + 1] - window[from]
                    if delta > 0 then
                        sumUp = sumUp - delta
                    elseif delta < 0 then
                        sumDn = sumDn - (-delta)
                    end
                    window[from] = nil
                    from = from + 1
                end
                -- Учёт предыдущей свечи как сформированной, внесём вклад в суммы
                if to - 1 >= from then
                    local delta = window[to] - window[to - 1]
                    if delta > 0 then
                        sumUp = sumUp + delta
                    elseif delta < 0 then
                        sumDn = sumDn + (-delta)
                    end
                end
                to = to + 1
            end
            lastIndex = index
            -- Новая свеча или обновление старой свечи
            window[to] = currPrice
            if to > from then
                local prevPrice = window[to - 1]
                local delta = currPrice - prevPrice
                local sumUp = sumUp
                local sumDn = sumDn
                if delta > 0 then
                    sumUp = sumUp + delta
                elseif delta < 0 then
                    sumDn = sumDn + (-delta)
                end
                if to - from + 1 == period + 1 then
                    lastIndicatorValue = (sumUp + sumDn <= 0) and 50 or (100 * sumUp / (sumUp + sumDn))
                else
                    lastIndicatorValue = nil
                end
            else
                lastIndicatorValue = nil
            end
        end
        return lastIndicatorValue
    end
end

10:03:21.979000 BRH7 55,83 Купля
10:03:22.005000 SRH7 17483 Продажа
10:03:21.953471 FEES 0,2425 Продажа