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

-- это main() создали основной поток
    -- создается сопрограмма 
    local routine = coroutine.create(Robot)
    while working do
   
      ---Запускается сопрограмма 
      local res, errmsg = coroutine.resume(routine)
      
      --(Обработка заказов (Orders) вызывает на каждой итерации сопрограммы)
      for trans_id, smartorder in pairs(SmartOrder.pool) do
        smartorder:process()
      end
     -- Здесь нет задержки
   end
   
function Robot()--сопрограмма
    
   -- Выполняется сопрограмма
   while working do
        
      for i=1,#sec do
          --... Обрабатываются стратегии
         rule[i] = 'buy'
         if then
             smartorder = 'buy'
              coroutine.yield() -- Переход в основной цикл
         end
      end
      sleep(1000)-- Здесь задержка
   end
end

--Пример реализации алгоритма переключения между задачами в Lua. Планировщик задач извлекает задачи из очереди и выполняет их одну за другой, пока очередь не станет пустой.

--Алгоритм (thread scheduler) в Lua

--1. Первым шагом является создание очереди задач, которая будет хранить задачи, ожидающие выполнения. В Lua это таблица в качестве очереди.
local task_queue = {}

--2. Затем мы создадим несколько функций задач, которые будут выполняться нашим планировщиком задач.
function task1()
    print("Выполнение задачи 1")
end

function task2()
    print("Выполнение задачи 2")
end

function task3()
    print("Выполнение задачи 3")
end

--3. Теперь мы можем добавить наши задачи в очередь задач.
table.insert(task_queue, task1)
table.insert(task_queue, task2)
table.insert(task_queue, task3)

--4. Далее мы реализуем сам планировщик задач. Планировщик будет извлекать задачи из очереди и выполнять их одну за другой.
function thread_scheduler()
    while #task_queue > 0 do
        -- Извлекаем первую задачу из очереди
        local task = task_queue[1]
        table.remove(task_queue, 1)

        -- Выполняем задачу
        task()
    end
end

--5. Наконец, мы запускаем планировщик задач, вызвав функцию thread_scheduler().
thread_scheduler()

--Пример вывода:
--Выполнение задачи 1
--Выполнение задачи 2
--Выполнение задачи 3

-- Обернуть функцию в сопрограмму
local my_coroutine = coroutine.wrap(function()
    print("Hello from coroutine")
end)

-- Запустить сопрограмму
coroutine.resume(my_coroutine) -- Выведет "Hello from coroutine"

Пример с отслеживанием времени работы, событиями котировок и исполнением сделок, использующий случайные числа для входов:

math.randomseed(os.time())-- Модуль для генерации случайных чисел

function generate_trading_time()-- Функция для получения случайного времени торгов
    return math.random(0, 24) -- Возвращает случайное время в часах (0-24)
end
function is_market_open(trading_time)-- Функция для проверки, находится ли рынок в рабочее время
    return trading_time >= 9 and trading_time <= 17
end
function generate_quote()-- Функция для получения случайной котировки
    return {
        bid = math.random(100, 110),
        ask = math.random(110, 120),
        volume = math.random(1000, 5000)
    }
end
    local threshold = 110
function generate_event(quote)-- Функция для генерации события "купить" или "продать"
    if quote.bid > threshold then
        return "buy"
    else
        return "sell"
    end
end
--function execute_trade(event)-- Функция для имитации исполнения сделки
--    print("Исполнена сделка:", event)
--end

----- Функции для тестового примера:
--[[Описание:
  generate_buy_event() и generate_sell_event() генерируют события “купить” и “продать” соответственно на основе предоставленной котировки. События включают тип сделки, цену и количество акций.
  receive_event() имитирует получение события “купить” или “продать” из внешнего источника.
  execute_trade() имитирует исполнение сделки на основе предоставленного события.
--]]

function generate_buy_event(quote)-- Функция для генерации события "купить"
    return {
        type = "buy",
        price = quote.bid,
        quantity = math.random(100, 1000)
    }
end
function generate_sell_event(quote)-- Функция для генерации события "продать"
    return {
        type = "sell",
        price = quote.ask,
        quantity = math.random(100, 1000)
    }
end

function receive_event()-- Функция для имитации получения события "купить" или "продать"
    -- В реальном приложении эта функция должна получать события из очереди событий или другого источника.
    -- Здесь мы имитируем получение события, используя случайное число.
    math.randomseed(os.time())
    local event_type = math.random() < 0.5 and "buy" or "sell"
    local price = math.random(100, 120)
    local quantity = math.random(100, 1000)

    return {
        type = event_type,
        price = price,
        quantity = quantity
    }
end

function execute_trade(event)-- Функция для имитации исполнения сделки
    print("Исполнена сделка:", event.type, event.price, event.quantity)
end

coroutine.wrap(function()-- Отслеживание времени торгов
    while true do
        -- Получить текущее время торгов
        local trading_time = generate_trading_time()

        -- Проверить, находится ли рынок в рабочее время
        if is_market_open(trading_time) then
            -- Перейти в режим торговли
            print("Переход в режим торговли")
        else
            -- Перейти в режим ожидания торгов
            print("Переход в режим ожидания торгов")
        end

        -- Задержка перед следующим обновлением времени торгов
        coroutine.yield()
    end
end)()
coroutine.wrap(function()-- Отслеживание котировок и генерация событий
    while true do
        -- Получить котировку акции
        local quote = generate_quote()

        -- Сгенерировать событие "купить" или "продать"
        local event = generate_event(quote)

        -- Отправить событие
        print("Сгенерировано событие:", event)
    end
end)()
coroutine.wrap(function()-- Исполнение сделок
    while true do
        -- Получить событие "купить" или "продать"
        local event = receive_event() -- В этом примере мы имитируем получение события
        -- Исполнить сделку
        execute_trade(event)
    end
end)()

-- Основной цикл приложения
while true do
    -- Выполнять другие задачи, такие как управление пользовательским интерфейсом
end

end

coroutine.wrap(function() -- пример функции обратного вызова для отслеживания времени торгов
    while run do
        -- Получить текущее время торгов
        local trading_time = get_trading_time() 
        print('trading_time =',trading_time)

        -- Проверить, находится ли рынок в рабочее время
        if is_market_open(trading_time) then
            -- Перейти в режим торговли
            start_trading()
            
        else
            -- Перейти в режим ожидания торгов
            stop_trading()
        end

        -- Задержка перед следующим обновлением времени торгов
        coroutine.yield()
    end
end)()
coroutine.wrap(function() -- пример функции обратного вызова для обработки событий котировок акций
    while run do
        local quote = generate_quote() -- Получить котировку
        process_quote(quote) -- Обработать котировку
    end
end)()

-- Этот класс equation содержит функции для расчета среднего HPR, дисперсии HPR, средневзвешенного f и среднего геометрического.
-- Определение класса equation
equation = {}

-- Функция для расчета среднеарифметического АHPR, дисперсии SDHPR и средневзвешенного f
function equation.calculate_mean_and_variance_with_f(HPR_values, f_values)
    local n = #HPR_values
    local mean_HPR = 0
    local total_f = 0

    -- Расчет среднего HPR
    for i = 1, n do
        mean_HPR = mean_HPR + HPR_values[i]
        total_f = total_f + f_values[i]
    end
    mean_HPR = mean_HPR / n

    -- Расчет дисперсии HPR
    local sum_squared_diff = 0
    for i = 1, n do
        sum_squared_diff = sum_squared_diff + (HPR_values[i] - mean_HPR) * (HPR_values[i] - mean_HPR)
    end
    local variance_HPR = sum_squared_diff / n

    -- Подсчет средневзвешенного f
    local mean_weighted_f = total_f / n

    return mean_HPR, variance_HPR, mean_weighted_f
end

-- Функция для расчета среднего геометрического с учетом полученных значений AHPR и стандартного отклонения
function equation.calculate_geometric_mean(AHPR, standard_deviation)
    local geometric_mean = math.sqrt(AHPR^2 - standard_deviation^2)
    return geometric_mean
end

-- Пример использования класса equation
local HPR_values = {0.05, 0.03, 0.07, 0.01, 0.06}
local f_values = {0.1, 0.15, 0.2, 0.05, 0.1}

local calculator = equation
local mean_HPR, variance_HPR, mean_weighted_f = calculator.calculate_mean_and_variance_with_f(HPR_values, f_values)

print("Среднее HPR: " .. mean_HPR)
print("Дисперсия HPR: " .. variance_HPR)
print("Средневзвешенное f: " .. mean_weighted_f)

local AHPR = mean_HPR
local standard_deviation = variance_HPR
local geometric_mean = calculator.calculate_geometric_mean(AHPR, standard_deviation)
print("Среднее геометрическое: " .. geometric_mean)

---- пример  расчета HPR (Holding Period Return):
--Эта функция принимает начальную цену актива, конечную цену актива и доход за период. Она вычисляет и возвращает показатель HPR (Holding Period Return) для данного периода владения.
function calculate_HPR(start_price, end_price, income)
    return ((end_price + income) / start_price) - 1
end

-- использования
local start_price = 100  -- Начальная цена актива
local end_price = 120    -- Конечная цена актива
local income = 5         -- Доход за период

local hpr = calculate_HPR(start_price, end_price, income)
print("HPR: " .. hpr)