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

--- Загрузка CPU ---
IsRun = true
function main()
    local T
   local hour = 0, N
   N = 1000000
    -------------------
    while IsRun do 
       T = os.clock() 
      for i = 1, N do hour = {} end      
      T = (os.clock() -T) * 1000 / N     ---- ### !! Без подключения к серверу: 1) В QUIK 8.13.1.16 (QLua 5.4)  T = 0,00016 ;     
                                                                ---                                                         2) В QUIK 9.3.1.11 (QLua 5.4)  T = 0,0026  ??? (в 16,25 раз дольше)
      message (tostring(T))
        sleep(500)  
    end
    ------------------
end   
   
function OnStop()
     IsRun = false
    return 10000   
end
 

J = 100000000   
 while ( J > 0  )   do   J = J - 1  end      -- ### Проблема здесь.   "Чистый" байт-код, но в QLua 5.3 здесь переключаются потоки (! в 5.4 этого нет) 

local for_OnParam = 2 -- Множитель 
local N_OnParam = 0
----
function OnParam(p1, p2)
    for i = 1, for_OnParam do 
      N_OnParam = N_OnParam + 1                                                                              
   end
end
---
--------
IsRun = true
function main()
    local J
    local OnParam_begin   
    -------------------
    while IsRun do 
     ------
     do
        OnParam_begin = N_OnParam   
             J = 100000000   
             while ( J > 0  )   do   J = J - 1  end      -- ### Проблема здесь.   "Чистый" байт-код, но в QLua 5.3 здесь переключаются потоки (! в 5.4 этого нет)---- 
--         for i = 1, 100000000 do  end        --  Это в QLua 5.3 работает нормально  ---

        if N_OnParam ~= OnParam_begin then   --  Счетчик N_OnParam может исмениться только в OnParam  
                message ( ' Переключение колбека и потока main:  N_OnParam - OnParam_begin = ' .. tostring(N_OnParam - OnParam_begin))
            end      
   end
   -----
       sleep(10)  
  end
  ------------------
end   
   
function OnStop()
     IsRun = false
    return 10000   
end

local WorkingFolder = getWorkingFolder()   
   package.cpath = package.cpath .. ';' .. WorkingFolder .. '\\?3.dll'      -- C - пакеты  ----
sqlite3 = require('lsqlite3');  ------  Подключение пакета работы с sqlite3  -----
---- Далее использовать функции работы с базами:  sqlite3.<Функция работы с базами>

-- Модуль таймерных событий OnTimer ---
    -- Подключение C-пакетов service53, service54: https://cloud.mail.ru/public/i3Y7/kQHBvs7um
local WorkingFolder = getWorkingFolder()   
package.cpath = package.cpath .. ';' .. WorkingFolder .. '\\?.dll' .. ';' .. WorkingFolder .. '\\?53.dll'.. ';' .. WorkingFolder .. '\\?54.dll' .. ';' .. WorkingFolder .. '\\?51.dll'
                            .. ';' .. WorkingFolder .. '\\?3.dll'      -- C - пакеты  ----
if _VERSION == 'Lua 5.3' then   
    require('service53')     -- Подключает библиотеку service.dll, расположенную в корневом каталоге терминала QUIK (там где info.exe)   ----
else
    require('service54')  
end   
local GetMilliseconds, Start_thread  =   service.GetMilliseconds, service.Start_thread

  --- Функции работы с очередями  ---
    local new  =   function  ()
        return  {first  =   1 , last  =   0 }
    end 
    ---
    local push  =   function  (self, v)
        local  last  =  self.last  +  1 
        self[last]  =  v
        self.last  =  last
        return  last
    end 
    ---
    local 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, first
     end 
--------- Создание очереди ------
 local  Queue_Timer = new()  --- Таймерные события -----
 local  Queue_Timer_Sl = new()  --- Очередь отмены событий ---
-------------------------------------------
    --- Заказ таймерных событий ----
    --- Таймерное событие:  {<Имя события>, <Интервал в млсек.>, <Функция обработки события>,{<Список парвметров функции>}}
    local function Set_Timer  (self)
       if type(self) == 'table' then 
         if #self >= 3 then
             self [2] = self [2] + GetMilliseconds() 
              return push (Queue_Timer, self)
         else
            message ( '!!! Ошибка. Должно быть:  {<Имя события>, <Интервал в млсек.>, <Функция обработки события>,{<Список парвметров функции>}}') 
         end
      else
         message ( '!!! Ошибка (параметр не таблица). Должно быть:  {<Имя события>, <Интервал в млсек.>, <Функция обработки события>,{<Список парвметров функции>}}') 
      end
    end 
   -----
    local function delete_Timer  (kl)
       push (Queue_Timer_Sl, kl)
    end 
    ------
    local function Timer ()
       local ms, first_q 
       while IsRun   do 
            ---  Обработка удалений событий ---
            ms, first_q = pop (Queue_Timer_Sl) 
            while ms  do
             if Queue_Timer [ms] then Queue_Timer [ms] = nil end
            ms, first_q = pop (Queue_Timer_Sl)    
         end
         ---  Чтение очереди заказанных событий[ -----   
          for k, v in next, Queue_Timer do
            if type(k) == 'number' then
                if v [2] <= GetMilliseconds()   then
                   Queue_Timer [k] = nil
                        if v[4] then
                           pcall ( v[3], table.unpack (v[4]))
                  else
                     pcall ( v[3])  -- функция без параметров ---
                  end
               end
            end
              end
         -------------------------------------------------------
            sleep(2)      
       end
    end 
---------------------------------------
    local function Start_Timer ()
     Start_thread (Timer)
    end
  ------
  return {Set_Timer = Set_Timer, delete_Timer = delete_Timer, Start_Timer = Start_Timer }

-- Шаблон использования модуля таймерных событий
local OnTi mer = require('OnTimer')  -- Подключение модуля обработки таймерных событий  ---
local Set_Timer = OnTimer.Set_Timer
local delete_Timer = OnTimer.delete_Timer
local Start_Timer = OnTimer.Start_Timer

IsRun = true

    local function call_Timer  (kl)
        message ( 'call_Timer = ' .. kl)
    end 
   
    local function call_Timer1  ()
        message ( 'call_Timer1  () ==============')
    end 

function main()
    Start_Timer()
   local kl
    --- Заказ таймерных событий ----
    --- Таймерное событие:  {<Имя события>, <Интервал в млсек.>, <Функция обработки события>,{<Список парвметров функции>}}
   kl = Set_Timer({'Set_Timer', 100, call_Timer, {100}})
   kl = Set_Timer({'Set_Timer', 1000, call_Timer, {1000}})
   kl = Set_Timer({'Set_Timer', 5000, call_Timer, {5000}})
   kl = Set_Timer({'Set_Timer', 3000, call_Timer1})
--   delete_Timer (kl)
   
    -------------------
    while IsRun do 
   
       ----  Обработка в main остального -----
       kl = Set_Timer({'Set_Timer', 1000, call_Timer, {1000}})
        delete_Timer (kl)
       ----  Конец Обработка в main остального -----
        sleep(500)        
  end
  ------------------
end   
   
function OnStop()
     IsRun = false
    DestroyTable(TableQUIK)
     DestroyTable(TableQUIK1)
    return 10000   --  !!  По истечении этого интервала времени (в млсек.), данного скрипту на завершение работы, функция main() завершается принудительно. 
                                -- При этом возможна потеря системных ресурсов.   ! Если функция не выдает значение, то по умолчанию оно 5000 (5 сек.)
end

   if ( lua_getglobal (<Основной State в котором запускается колбек>, <Имя колбека>) == LUA_TFUNCTION)     // запись и проверка переменной колбека скрипта в стек
   { 
       if ( lua_pcall(<Основной State в котором запускается колбек>, <Количество параметров колбека>, <Список параметров колбека>)  ~= 0 )   // запуск колбека 
      {
          <Обработка ошибки при запуске колбека>
      }
    }
   else    //  в переменной колбека не функция
   {
        <Обработка ошибки пользователя, задавшего в качестве колбека не функцию>
   }

  --- Функции работы с очередями (написаны на "чистом" Lua без обращения к C-функциям)  ---
    local new  =   function  ()
        return  {first  =   1 , last  =   0 }
     end 
    ---
    local push  =   function  (self, v)
        local  last  =  self.last  +  1 
        self[last]  =  v
        self.last  =  last
        return  last
     end 
    ---
    local 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, first
     end 
    ---
    local size  =   function  (self)
        return  self.last  -  self.first  + 1 
     end 
-----
--------- Создание очереди------
local  Queue_QUIK = new()
---------------------------------------

---  Основной поток обработки колбеков "обходит", запушенные на выполнение скрипты, с тем чтобы по событиям запускать их колбеки.
--  При этом должна быть обеспечена корректная синхронизация выполнения байт-кода колбека таким образом, что он не может выполняеться 
--  параллельно с байт-кодом потока main.
----------------------
local for_OnParam = 2 -- Множитель количества записей в очередь ----
local N_OnParam = 0
--- OnParam написана на "чистом" Lua без обращения к C-функциям  ---
function OnParam(p1, p2)
    for i = 1, for_OnParam do 
      N_OnParam = N_OnParam + 1
      -- Зпаись события  ---
      push (Queue_QUIK, {'OnParam', N_OnParam, {p1, p2}})   --  1. здесь создаются таблицы и может быть запущена автоматическая сборка мусора, 
                                                                                            --     которая работает для всей инсталяции Lua и не является потокобезопасной ---                                                                              
   end 
end
   
 ----   Обработка событий QUIK  (написана на "чистом" Lua без обращения к C-функциям) ----      
local function handle_events()   
      ----- ####  Для отладки ---
   local OnParam_begin = N_OnParam   
   local size_Queue_QUIK = size(Queue_QUIK)
   ---------------------------------
   ---  Чтение очереди событий -----
   local ms, first_q = pop (Queue_QUIK) 
      
    while ( ms  )   do        --- Есть события --- 
       -------------------------------
        ---  Чтение очереди событий -----      
        ms, first_q = pop (Queue_QUIK)  --Queue_QUIK: pop()         
   end
    ---   
    for i = 1, 1000 do      end  ---- нагрузка   ####  Отладка ---
   
    if N_OnParam ~= OnParam_begin then   --  Счетчик N_OnParam может иpмениться только в OnParam  
                                                              --  А это означает, что одновременно (параллельно) работают поток main и основной 
                         --  поток обработки колбеков, что недопустимо.
   --- это C-функция, но она вызывается только если  N_OnParam ~= OnParam_begin 
         message ( ' Параллельное выполнение колбека и потока main:  N_OnParam - OnParam_begin = ' .. tostring(N_OnParam - OnParam_begin)
                        .. '    size_Queue_QUIK = ' .. tostring(size_Queue_QUIK) )
    end      
    ----
end      
--------------------------------------------------------------------------------------------------------------------
--------
IsRun = true
function main()
    -------------------
    while IsRun do 
        handle_events()  ----   функция чтения событий OnParam ---
        sleep(2)  
    end
  ------------------
end   
   
function OnStop()
     IsRun = false
    return 10000   
end