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

---- Реализация циклических потокобезопасных очередей без синхронизации для случая, когда один поток в нее пишет, а другой читает  (!не допустимы чтения или записи в нескольких потоках)------
local Queue_safe = {
  ---  size_Queue - размер очереди  ----
  new = function (self, size_Queue)
    local  Queue = {}
    local  cycl = {}      -- таблица-массив хранения элементов очереди
    for i =1, size_Queue do 
        cycl[i] = 0 
   end
   Queue.cycl = cycl
    Queue.QueueLength = size_Queue  --- размер очереди    ---
    Queue.RecordPointer = 1   ---  указатель записи  (изменяется только "писателем")     ---
    Queue.ReadingPointer = 1 ---  указатель чтения  (изменяется только "читателем")     ---
   Queue.written_down = 0   --- количество записанных элементов ---
   Queue.read = 0  --- количество считанных элементов ---
    return setmetatable(Queue, {__index = self})     --- для переключения на Queue_safe при обращение в созданной таблице к push, pop, size  ----
  end,
  
  --- Записываемое в очередь значение не может быть nil  --
  --  Результат: 0 - запись выполнена;  1 -  запись не выполнена (нет места) 
  push = function (self, v)  
        if v == nil then  error(' !!! В очередь нельзя записывать  nil ')  end
      if  self.written_down - self.read >= self.QueueLength then      ----- некуда писать  ----
              return (1)   
        end
        local  cycl = self.cycl
        local pwt=  self.RecordPointer
      cycl [pwt] = v
      local pwf =  pwt +1
        if  pwf  > self.QueueLength then
             pwf=1
        end
        self.RecordPointer = pwf  --- следующая позиция для записи (возможно занятая) --   
      self.written_down = self.written_down + 1
        return (0)
  end,
 
  ---  Два результата: 1) элемент или nil;     2) признак: 0 - очередь после чтения пуста;  > 0 - количество непрочитанных элементов;   -1 - очередь пуста в момент чтения;
  pop = function (self)
      local n = self.written_down - self.read 
      if  n == 0 then
           return nil, -1  --- нет данных
      end
     local  cycl = self.cycl 
     local prt=  self.ReadingPointer
     local v = cycl [prt]
     cycl [prt] = 0      ---  чтобы не было "висячих" ссылок на ссылочные объекты  ----
      prt =  prt +1
      if  prt  > self.QueueLength then
            prt = 1
      end
     self.ReadingPointer = prt
     self.read = self.read + 1
     return  v,  n - 1 
  end,

  size = function (self)
    return self.written_down - self.read
  end
}
----------------------------------------------------------------------
                                                                                            ------  Тесты  -----
local T 
local v
--[[
 --  1.  Этот фрагмент (использование потокобезопасных функций QLua)   (100 000 записей и чтений)  выполняется за ~3560 милисекунд ---
T = {}
for j = 1, 100  do 
  for i = 1, 1000 do  --- запись в очередь
     table.sinsert (T, 'sd')   
  end

  for i = 1, 1000 do  --- чтение из очереди
     v = T[1]
    table.sremove (T, 1)
  end
end
do return end      ------
 -----------------------------------------------------------------
--]]

 --  2. Этот фрагмент (использование Queue_safe)   (100 000 записей и чтений)  выполняется за ~55 милисекунд ---
T = Queue_safe:new(1200) 
  
 for j = 1, 100  do 
  for i = 1, 1000 do  --- запись в очередь
     T: push('sd')
  end

  for i = 1, 1000 do  --- чтение из очереди
     v = T: pop()
  end
end
--------------------------------------------------------------

----  Скрипт -тест  ----
 --  Этот фрагмент выполняется  ~500 милисекунд ---
local T = {}
local v
for j = 1, 10  do 
  for i = 1, 1000 do  --- запись в очередь
     table.sinsert  (T, {'sdfdfmffmf', 57})
--     v = T[1]
--    table.sremove(T, 1)
  end

  for i = 1, 1000 do  --- чтение из очереди
 --    table.sinsert  (T, {'sdfdfmffmf', 57})
     v = T[1]
    table.sremove(T, 1)
  end
end

-- Функция определения пути файла запускаемого скрипта ---
 -- Результат: если запуск файла, то путь файла; если строка, то результат nil   ---
function script_path() 
   local str 
   for i = 2, 10000 do  --- поиск корневой функции, вызывающей script_path, начиная с функции в которой вызвана script_path
 --     message (tostring(  debug.getinfo(i) ))
      if  debug.getinfo(i)  then   ---- 
        str = debug.getinfo(i, "S").source
     else
        break
     end
   end

   if  str:sub(1,1) ~= '@' then  ---- ! путь к файлу или имя пакета содержит символ '@'
      return  'Вызов строки'  ---   
   end
   if  not str: find ('\\', 1)  then  --- нет пути к файлу
      return str:sub(2)    --- имя пакета ---
   end
   --  выделение пути файла скрипта ----
   str = str:sub(2) 
   str = str:match('(.*[/\\])') or '.\\'
   str = str: sub(1, #str -1)
   return str
end

function OnInit(script)
 is_run = true
 MAIN_QUEUE = {}
end

function OnOrder(order)
table.sinsert(MAIN_QUEUE, {callback = "OnOrder", value = order})
end

function OnTrade(trade)
   table.sinsert (MAIN_QUEUE, {callback = "OnTrade", value = trade})
end

function OnAllTrade(all_trade)
table.sinsert(MAIN_QUEUE, {callback = "OnAllTrade", value = all_trade})
end

function OnQuote(class_code, sec_code)
local quote = getQuoteLevel2(class_code, sec_code)
table.sinsert(MAIN_QUEUE, {callback = "OnQuote", value = quote})
end

function OnStop()
is_run = false
return 2000
end

function main()
  while is_run do
    if #MAIN_QUEUE > 0 then
       ProcessingCallbakc(MAIN_QUEUE[1])
       table.sremove(MAIN_QUEUE, 1)
       message("Размер очереди " .. tostring(#MAIN_QUEUE))
    end
 end
end

function ProcessingCallbakc(value)
  message(string.format("Обработка события %s начата", value.callback))
  sleep(3000) --эмуляция продолжительного алгоритма обработки события
  message(string.format("Обработка события %s завершена", value.callback))
end