Очереди и двойные очереди в луа

function rescanBigDeals(sec_code, class_code)

   local all_trades_count = getNumberOf("all_trades")

   local endIndex = LastReadDeals
   local beginIndex = 1

    params = {sec_code=sec_code,class_code=class_code}
    local t1 = SelectItems("all_trades", 1, endIndex, params)
    if t1 ~= nil then
        endIndex = #t1
    else
        endIndex = 0
    end

    --myLog("rescan begin "..tostring(beginIndex).." - "..tostring(endIndex))

    local lastClaster = nil

   for i = beginIndex, endIndex, 1 do

      local at = getItem ("all_trades", t1[i])

        if at ~= nil then

            local datetime = os.time(at.datetime)

            if curDate.day == at.datetime.day or curDate.wday==1 or curDate.wday==7 then

                local value = 0
                --if CountQuntOfDeals == 1 then
                --    value = 1
                --elseif sum_quantity == 0 then
                --    value = at.value
                --else
                    value = at.qty
                --end

                local itsSell = bit.band(at.flags, 0x1) ~= 0
                if dirTradeType == 2 and SecData[at.sec_code]["lastDealPrice"]~=0 and at.price~=SecData[at.sec_code]["lastDealPrice"] then
                    itsSell = at.price<SecData[at.sec_code]["lastDealPrice"]
                end
                SecData[at.sec_code]["lastDealPrice"] = at.price

                --myLog("deal "..at.sec_code.." qnt "..tostring(at.qty).." deal n:"..tostring(at.trade_num).." "..isnil(toYYYYMMDDHHMMSS(at.datetime)))

                if lastClaster == nil then
                    lastClaster = {datetime = at.datetime, mcs = at.datetime.mcs, qty = 0, value = 0, price = 0, isSell = itsSell, sellVol = 0, buyVol = 0} -- time, qty, vol, wvap
                end
                local needNewClaster = false
                if SecData[at.sec_code]["clasterTime"] == 0 and lastClaster["mcs"] ~= at.datetime.mcs then
                    needNewClaster = true
                elseif SecData[at.sec_code]["clasterTime"] ~= 0 
            and ((at.datetime.sec-lastClaster["datetime"].sec+1) > SecData[at.sec_code]["clasterTime"] 
            or lastClaster["datetime"].min ~= at.datetime.min or lastClaster["datetime"].hour ~= at.datetime.hour) then
                    needNewClaster = true
                end

                --myLog("needNewClaster "..tostring(needNewClaster))

                if needNewClaster then
                    if lastClaster["value"]~=0 then
                        lastClaster["price"] = lastClaster["price"]/lastClaster["value"]
                    else
                        lastClaster["price"] = at.price
                    end
                    lastClaster.datetime = at.datetime
                    local clasterQty = lastClaster["qty"]

                    if SecData[at.sec_code]["bigDealSize"]~=0 and clasterQty >= SecData[at.sec_code]["bigDealSize"] then
                        myLog("big deal "..at.sec_code.." qnt "..tostring(clasterQty).." "..isnil(toYYYYMMDDHHMMSS(at.datetime)))
                        if lastClaster["buyVol"]>lastClaster["sellVol"] then
                            lastClaster["isSell"] = false
                        elseif lastClaster["buyVol"]>lastClaster["sellVol"] then
                            lastClaster["isSell"] = true
                        end
                        addBigDealLabel(at.sec_code, lastClaster)
                    end
                    lastClaster = {datetime = at.datetime, mcs = at.datetime.mcs, qty = 0, value = 0, price = 0, isSell = itsSell, sellVol = 0, buyVol = 0} -- time, qty, vol, wvap
                end

                lastClaster["qty"] = lastClaster["qty"] + at.qty
                lastClaster["value"] = lastClaster["value"] + at.value
                lastClaster["price"] = lastClaster["price"] + at.value*at.price
                if itsSell then --sell
                    lastClaster["sellVol"] = lastClaster["sellVol"] + at.qty
                else
                    lastClaster["buyVol"] = lastClaster["buyVol"] + at.qty
                end

                --if lastClaster == nil then
                --    lastClaster = {datetime = at.datetime, mcs = at.datetime.mcs, qty = 0, value = 0, price = 0, isSell = itsSell} -- time, qty, vol, wvap
                --elseif lastClaster["mcs"] ~= at.datetime.mcs then
                --    lastClaster["price"] = lastClaster["price"]/lastClaster["value"]
                --    local clasterQty = lastClaster["qty"]
                --    if SecData[at.sec_code]["bigDealSize"]~=0 and clasterQty >= SecData[at.sec_code]["bigDealSize"] then
                --        myLog("big deal "..at.sec_code.." qnt "..tostring(clasterQty).." deal n:"..tostring(at.trade_num).." "..isnil(toYYYYMMDDHHMMSS(at.datetime)))
                --        addBigDealLabel(at.sec_code, lastClaster)
                --    end
                --    lastClaster = {datetime = at.datetime, mcs = at.datetime.mcs, qty = 0, value = 0, price = 0, isSell = itsSell} -- time, qty, vol, wvap
                --end
                --
                --lastClaster["qty"] = lastClaster["qty"] + at.qty
                --lastClaster["value"] = lastClaster["value"] + at.value
                --lastClaster["price"] = lastClaster["price"] + at.value*at.price

                addTradeStat(at, value, itsSell)
            end
        end
    end

    if SecData[sec_code]["showHourVWAP"] == 1 then
        for k,n in pairs(SecData[sec_code]["h_vwap"]) do
            addPriceLabel(sec_code, n, 3, 0)
        end
    end
    if SecData[sec_code]["showDayVWAP"] == 1 then
        addPriceLabel(sec_code, SecData[sec_code]["vwap"], 5, -2)
    end

    if curDate.wday==1 or curDate.wday==7 then
        updateSecs()
    end

    rescanSec = nil
    rescanning = false
end

 
    local is_run;
function OnStop(flag)--вызывается при остановке скрипта из диалога управления
-- 2.2.24 Функция вызывается терминалом QUIK при остановке скрипта из диалога управления.

   is_run = false
   return 1000
end
function OnClose()--Функция вызывается перед закрытием терминала QUIK и при выгрузке файла qlua.dll. 
is_run = false
end
--function OnInit() -- вызывается терминалом QUIK перед вызовом функции main (2.2.25 OnInit)
--end
--local class,symbol;
function main()-- Функция, реализет основной поток выполнения в скрипте.(2.2.26 main) 
    
   
   
   is_run = true;
   
   --local list=List.new();
    -- message('0 '..'first='..tostring(list.first)..'; '..'last='..tostring(list.last) )
   --local AT=allt:new();
      class= "SPBFUT";
       symbol='RMU3'--NGN3';
      
       -----------all_trades
      --Если перечисленные параметры отсутствуют в списке полей элемента, то в качестве параметра передается nil. 
        
      function fn(par1,par2)
          if par1 == class and par2 == symbol then
                 return true
          else
              return false
          end
      end
      local t1 = nil;
      --[[---- возвращает таблицу с индексами элементов, удовлетворяющих условию поиска
      t1 = SearchItems("all_trades", 0, getNumberOf("all_trades")-1, fn, "class_code, sec_code")

       local at=nil;
      --local number_of_rows = getNumberOf('all_trades')   
      local first,last=1,#t1;
        for i = 1, #t1 do
             at = getItem('all_trades', i)
          if at --and at.sec_code==symbol 
          then
             List.pushlast(list, at);
             --AllTrade();
             List.popfirst(list);
          end
      end   
      --]]
      local first=0;
      local at = nil;
      --message('1 '..'first='..tostring(list.first)..'; '..'last='..tostring(list.last) )
       ----
       local j=1;
   while is_run do ----- основной поток выполнения скриптa:
   
      local last=getNumberOf("all_trades"); 
      message(j..' '..'first='..tostring(first)..'; '..'last='..tostring(last) )
      if last>first then
      
        ---- возвращает таблицу с индексами элементов, удовлетворяющих условию поиска При возникновении ошибки в функции fn функция SearchItems прерывает свою работу и возвращает «nil». 
        t1 = SearchItems("all_trades", first, getNumberOf("all_trades")-1, fn, "class_code, sec_code")
        if t1 then
        
         message(j..'): '..'first='..tostring(first)..'; last='..tostring(last)..'; #t1='..tostring(#t1) ..'; t1[1]='..tostring(t1[1])..'; t1[#t1]='..tostring(t1[#t1]))
            at = {};
         for i = t1[1], t1[#t1] do
         
             if not is_run then break end
          
          at = getItem('all_trades', i)
          --if at and at.sec_code==symbol then
          --List.pushlast(list, at);
          --AllTrade();
          --List.popfirst(list);
          --end
         
          local d = at and get_date(at.datetime) or 0;
          local t = at and get_time(at.datetime) or 0;
          local sec = at and at.sec_code or 'x';
          local p = at and at.price or 0;
          local q = at and at.qty or 0;
          
          local dir = (at and bit.test(at.flags,0) and -1 or 1) or 0; 
          
          --if bit.test(at.flags, 0) then ---- Если сделка на продажу, вычитает объем из текущего 
             --   dir=-1;
           --else -- Если сделка на покупку, прибавляет объем к текущему
             --   dir=1; 
           --end
          
          message(j..'): ('..i..'); '..tostring(d)..'; '..tostring(t)..'; '..tostring(sec)..'; '.. tostring(p)..'; '..tostring(q*dir)..'; '..tostring(dir) );
          
          end
          first=getNumberOf("all_trades");--last;--t1[#t1];
        end
      end
      j=j+1;
        --message(j..' '..'first='..tostring(first)..' list.first='..tostring(list.first)..'; '..'list.last='..tostring(list.last) )
      sleep(1000);
      
   end
end