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

----   Функции работы с очередями --
--- При использовании между потоком колбеков и потоком main очереди потокобезопасные. ---
--- Создать очередь 
function QueueNew()
   return  {first = 1, last = 0 }
end
---  Записать в очередь --
function QueuePush(self, v)
   if v == nil then error('!!! Ошибка. Параметр v функции QueuePush nil') end
   local last = self.last + 1 
   self[last] = v
   self.last = last
   return last - self.first + 1    -- количество элементов в очереди ---
end 
---  Читать очередь  --
function QueuePop(self)
   local  first =  self.first
   if  first > self.last then return nil   end 
   local v, v1  =  self[first], self[first + 1]
   self.first = first + 1 
   self[first] =  nil 
   v1 = type (v1) == 'string' and #v1 or 0
   return  v, v1   -- v1 -длина следующего элемента (если строка) ---
end
  
-- Текущий размер очереди ---
function QueueSize(self)
   return self.last - self.first + 1 
end 

while _RUN_ do
    ---Тело основного цикла скрипта --
end
if  TBL_QUIK then  -- Если используются таблицы QUIK
     -- #### Задержка sleep нужна чтобы установился признак запуска скрипта при перезапуске QUIK. 
     -- Иначе при перезапуске QUIK не будет перезапущен скрипт.--
     -- При нормальном завершении QUIK, если есть таблицы QUIK, они удаляются (и вызываются коллбеки QTABLE_CLOSE)
     -- Если при этом нет задержки, то скрипт завершается и не выставляется признак необходимости его перезапуска
     -- при запуске QUIK. Признак TBL_QUIK  устанавливается в основной пользовательской таблице QUIK. 
     -- Длительность задержки выбрана экспериментально.
     sleep(1000) 
end 

KW 02.12.25 10:01:00:071  -> Подана начальная лимитная заявка открытия позиции. TRADER.SetOrder
KW 02.12.25 10:01:07:168  ->  Создана позиция на акцию MTLR 

Version=1
EventType=BEX64
EventTime=134091324829545188
ReportType=2
Consent=1
UploadTime=134091324839947229
ReportStatus=268435456
ReportIdentifier=f78c1db2-991c-48e7-b3aa-345bbeae0654
IntegratorReportIdentifier=ddcd0da6-12c1-4cf9-be3a-ed050ce1a7bc
Wow64Host=34404
NsAppName=info.exe
OriginalFilename=INFO.EXE
AppSessionGuid=0000f9ac-0001-001e-4462-e0473c60dc01
TargetAppId=W:000672777e56bdcba4ff36fdbc37cc2c8d7200001904!0000d0c4dc424c674b736b0abeeba3e877466abdb072!info.exe
TargetAppVer=2025//11//19:13:06:13!1188a81!info.exe
BootId=4294967295
TargetAsId=74913
UserImpactVector=269484848
IsFatal=1
Response.BucketId=eb2cc38200ec50eaebef38537bcd66cf
Response.BucketTable=5
Response.LegacyBucketId=2012889489668400847
Response.type=4
Sig[0].Name=Имя приложения
Sig[0].Value=info.exe
Sig[1].Name=Версия приложения
Sig[1].Value=12.8.1.6                                            -- ####  QUIK
Sig[2].Name=Отметка времени приложения
Sig[2].Value=691dc0c5
Sig[3].Name=Имя модуля с ошибкой
Sig[3].Value=lua54.dll                                           -- ####  lua54.dll (разработка от ARQA)
Sig[4].Name=Версия модуля с ошибкой
Sig[4].Value=4.6.3.1                                             -- ####   ??
Sig[5].Name=Отметка времени модуля с ошибкой
Sig[5].Value=68db6225
Sig[6].Name=Смещение исключения
Sig[6].Value=00000000000452a8
Sig[7].Name=Код исключения
Sig[7].Value=c0000409                                          -- ####  Код исключения c0000409
Sig[8].Name=Данные исключения
Sig[8].Value=0000000000000007
DynamicSig[1].Name=Версия ОС
DynamicSig[1].Value=10.0.26200.2.0.0.256.48
DynamicSig[2].Name=Код языка
DynamicSig[2].Value=1049
DynamicSig[22].Name=Дополнительные сведения 1
DynamicSig[22].Value=5399
DynamicSig[23].Name=Дополнительные сведения 2
DynamicSig[23].Value=53994b242e91f2f520fb924ad8209cd4
DynamicSig[24].Name=Дополнительные сведения 3
DynamicSig[24].Value=f682
DynamicSig[25].Name=Дополнительные сведения 4
DynamicSig[25].Value=f68274b370b0a8397490f9d1d1f9fd15
UI[2]=C:\QUIK_VTB\info.exe
LoadedModule[0]=C:\QUIK_VTB\info.exe
LoadedModule[1]=C:\WINDOWS\SYSTEM32\ntdll.dll
LoadedModule[2]=C:\WINDOWS\System32\KERNEL32.DLL
LoadedModule[3]=C:\WINDOWS\System32\KERNELBASE.dll
 ...

RUN = true
function main()
   -- Функции для асинхронного запроса свечей ---
-- 1. Массовый запрос свечей BulkRequestCandles.
-- Параметр: таблица {{class_code, sec_code, interval}}
-- Результат: {{class_code, sec_code, interval, ds}}
   local BulkRequestCandles = function(par)
      for i = 1, #par do
         par[i].ds = CreateDataSource(par[i].class_code, par[i].sec_code, par[i].interval)
      end
   end
----------------------------------------

   -- 2. Проверка запроса свечей CheckingCandleRequest.
   -- Параметр: таблица {{class_code, sec_code, interval, ds}}
   -- Результат в таблице парамктров : {{class_code, sec_code, interval, ds, ok}}
   -- Значения ok: true - данные начали поступать; nil данные еще не поступили; 
   --              false - ошибка в параметрах запроса
   -- Знвчение функции: количеситво источников еще ожидающих данные --
   local CheckingCandleRequest = function(par)
      local N = #par
      local ds
      for i = 1, #par do
         ds = par[i].ds
         if type(ds) == 'string' then -- обнаруженная ранее ошибка в параметрах запроса
             N = N - 1
         else
            if par[i].ok == nil then  -- еще не дождались данных
               if ds == nil then      -- обнаружена ошибка
                  par[i].ds = '  *** Ошибка в параметрах запроса'
                  par[i].ok = false
               else
                  -- проверка поступления данных
                  if ds:Size() > 0 then -- есть данные 
                     par[i].ok = true
                     N = N - 1 
                  end
               end
            else 
               N = N - 1 
            end
         end
      end
      return N
   end
   -------------------------------------------------
   local  sec_list = {}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 1}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 2}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 5}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 10}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'SBER', interval = 20}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'GAZP', interval = 10}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'GAZP', interval = 2}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'GAZP', interval = 5}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'LKOH', interval = 5}
   sec_list[#sec_list+1] = {class_code = 'QJSIM', sec_code = 'FEES', interval = 5}
   sec_list[#sec_list+1] = {class_code = 'SPBFUT', sec_code = 'SiZ5', interval = 5}
   sec_list[#sec_list+1] = {class_code = 'SPBFUT', sec_code = 'RIZ5', interval = 5}
   sec_list[#sec_list+1] = {class_code = 'SPBFUT', sec_code = 'RIZ5', interval = 15}
   sec_list[#sec_list+1] = {class_code = 'SPBFUT', sec_code = 'SRZ5', interval = 30}

   BulkRequestCandles(sec_list)
   --------------
   local DS = false
   while RUN do
      -- Проверка поступления свечей (без блокирования цикла обработки)
      
      if CheckingCandleRequest(sec_list) == 0 and not DS then
         DS = true
         -- Отладочная печать --
         for i = 1, #sec_list do
            if sec_list[i].ok == true then 
               message(sec_list[i].sec_code ..'  ds:size() = ' .. sec_list[i].ds:Size()
                        ..'  interval = ' .. sec_list[i].interval)
            else  -- Ошибка задания параметров
               message(sec_list[i].sec_code..'  interval = ' .. sec_list[i].interval
                        .. sec_list[i].ds )
            end
         end
      end
      
      --  Выполнение заданий скрипта --
      
      sleep (100)
   end 
end

function OnStop(signal)
   RUN = false
   return 5000
end

   function main()
   local N =100000
   local function foo () 
      local yield = coroutine.yield
      while 1 do
           yield() 
      end
   end   
   local function foo1 () return  end
   -----
   local out = 'Результат теста: количество вызовов = ' .. N .. ', время вызова сопрограммы '
               
   local resume = coroutine.resume
   local co = coroutine.create(foo)
   local TT1 = os.clock()
      for i =1, N do  resume(co) end
   TT1 = (os.clock() - TT1) * 1000
   out = out .. TT1 .. ' млс.'
   -- message('coroutine = ' .. (os.clock() - TT) * 1000)
   local TT2 = os.clock()
      for i =1, N do  foo1(10) end
   TT2 = (os.clock() - TT2) * 1000   
   -- message('function = '.. (os.clock() - TT) * 1000) 
   out = out .. ', функции ' .. TT2 .. ' млс. T1/T2 = ' .. TT1/TT2 
   message(out)
end