Подвешивание info.exe через механизм межпоточного локинга

tid = 0

events = {}
mp_counter = 0
qp_counter = 0

-- Predicates to be called from two threads
-- To hang Quik we will try to collide QLUA functions
-- Risk factors: we're using heavily CriticalSection (through ssort) and the events are fast enough

-- Predicate for script's dedicated thread
function main_predicate(a, b)
   mp_counter = mp_counter + 1;
   if ((mp_counter % 7) == 0) then Clear(tid) end
   SetWindowCaption(tid, "Just called script thread predicate " .. mp_counter .. " times")
   local n = InsertRow(tid, -1)
   SetCell(tid, n, 1, "Compared " .. a .. " and " .. b .. " with script thread predicate", 0);
   return b > a
end

-- Predicate for Quik's main thread
function quik_predicate(a, b)
   qp_counter = qp_counter + 1;
   if ((qp_counter % 13) == 0) then Clear(tid) end
   local n = InsertRow(tid, -1)
   SetCell(tid, n, 1, "Compared " .. a .. " and " .. b .. " with main thread predicate", 0);
   SetWindowCaption(tid, "Just called quik thread predicate " .. qp_counter .. " times")
   return a < b
end

function main()
   Subscribe_Level_II_Quotes("QJSIM", "LKOH");
   Subscribe_Level_II_Quotes("QJSIM", "SBER");
   Subscribe_Level_II_Quotes("QJSIM", "GMKN");
   Subscribe_Level_II_Quotes("QJSIM", "SBERP");
   Subscribe_Level_II_Quotes("QJSIM", "MGNT");
   Subscribe_Level_II_Quotes("QJSIM", "ROSN");
   Subscribe_Level_II_Quotes("QJSIM", "AFLT");
   Subscribe_Level_II_Quotes("QJSIM", "BANE");
   Subscribe_Level_II_Quotes("QJSIM", "MTLR");
   Subscribe_Level_II_Quotes("QJSIM", "BANEP");

   tid = AllocTable()
   AddColumn(tid, 1, "Event", true, QTABLE_STRING_TYPE, 80)
   CreateWindow(tid)
   local cycles = 0;
   while true do
      sleep(1)
      cycles = cycles + 1;
      if (cycles == 100) then
         table.ssort(events, main_predicate)
         if (table.getn(events) > 0) then
            local n = InsertRow(tid, -1)
            SetCell(tid, n, 1, "First item after sorting in main is: " .. events[1], 0)
         end
         cycles = 0
      end
   end
end

function OnQuote(class_code, sec_code)
   local q = getQuoteLevel2(class_code, sec_code)
   if ((q ~= nil) and (tonumber(q.bid_count) > 0)) then
      if (table.getn(events) > 2) then events = {} end
      table.sinsert(events, q.bid[1].price)
      table.ssort(events, quik_predicate)
      if (table.getn(events) > 0) then
         local n = InsertRow(tid, -1)
         SetCell(tid, n, 1, "First item after sorting in main is: " .. events[1], 0)
      end
   end
end

tid = 0

events = {}
mp_counter = 0
qp_counter = 0

-- Predicates to be called from two threads
-- To hang Quik we will try to collide QLUA functions
-- Risk factors: we're using heavily CriticalSection (through ssort) and the events are fast enough

-- Predicate for script's dedicated thread
function script_predicate(a, b)
   print("SCRIPT: script_predicate entry")
   mp_counter = mp_counter + 1;
   if ((mp_counter % 7) == 0) then
      print("SCRIPT: Calling Clear")
      Clear(tid)
      print("SCRIPT: Returned from Clear")
   end
   print("SCRIPT: Calling SetWindowCaption")
   SetWindowCaption(tid, "Just called script thread predicate " .. mp_counter .. " times")
   print("SCRIPT: Returned from SetWindowCaption")
   print("SCRIPT: Calling InsertRow")
   local n = InsertRow(tid, -1)
   print("SCRIPT: Returned from InsertRow")
   print("SCRIPT: Calling SetCell")
   SetCell(tid, n, 1, "Compared " .. a .. " and " .. b .. " with script thread predicate", 0);
   print("SCRIPT: Returned from SetCell")
   print("SCRIPT: script_predicate end")
   return b > a
end

-- Predicate for Quik's main thread
function main_predicate(a, b)
   print("MAIN: main_predicate entry")
   qp_counter = qp_counter + 1;
   if ((qp_counter % 7) == 0) then
      print("MAIN: Calling Clear")
      Clear(tid)
      print("MAIN: Returned from Clear")
   end
   SetWindowCaption(tid, "Just called main thread predicate " .. cp_counter .. " times")
   print("MAIN: Returned from SetWindowCaption")
   print("MAIN: Calling InsertRow")
   local n = InsertRow(tid, -1)
   print("MAIN: Returned from InsertRow")
   print("MAIN: Calling SetCell")
   SetCell(tid, n, 1, "Compared " .. a .. " and " .. b .. " with main thread predicate", 0);
   print("MAIN: Returned from SetCell")
   print("MAIN: main_predicate end")
   return a < b
end

function main()
   -- Turn off buffering to stdout
   io.stdout:setvbuf("no")
   
   Subscribe_Level_II_Quotes("QJSIM", "LKOH");
   Subscribe_Level_II_Quotes("QJSIM", "SBER");
   Subscribe_Level_II_Quotes("QJSIM", "GMKN");
   Subscribe_Level_II_Quotes("QJSIM", "SBERP");
   Subscribe_Level_II_Quotes("QJSIM", "MGNT");
   Subscribe_Level_II_Quotes("QJSIM", "ROSN");
   Subscribe_Level_II_Quotes("QJSIM", "AFLT");
   Subscribe_Level_II_Quotes("QJSIM", "BANE");
   Subscribe_Level_II_Quotes("QJSIM", "MTLR");
   Subscribe_Level_II_Quotes("QJSIM", "BANEP");

   tid = AllocTable()
   AddColumn(tid, 1, "Event", true, QTABLE_STRING_TYPE, 80)
   CreateWindow(tid)
   local cycles = 0;
   while true do
      sleep(1)
      cycles = cycles + 1;
      if (cycles == 100) then
         print("SCRIPT: Calling ssort")
         table.ssort(events, script_predicate)
         print("SCRIPT: Returned from ssort")
         if (table.getn(events) > 0) then
            print("SCRIPT: Calling InsertRow")
            local n = InsertRow(tid, -1)
            print("SCRIPT: Returned from InsertRow")
            print("SCRIPT: Calling SetCell")
            SetCell(tid, n, 1, "First item after sorting in main is: " .. events[1], 0)
            print("SCRIPT: Returned from SetCell")
         end
         cycles = 0
      end
   end
end

function OnQuote(class_code, sec_code)
   print("MAIN: OnQuote entry")
   local q = getQuoteLevel2(class_code, sec_code)
   if ((q ~= nil) and (tonumber(q.bid_count) > 0)) then
      print("SCRIPT: Calling getn")
      if (table.getn(events) > 8) then events = {} end
      print("SCRIPT: Returned from getn")
      print("SCRIPT: Calling sinsert")
      table.sinsert(events, q.bid[1].price)
      print("SCRIPT: Returned from sinsert")
      print("SCRIPT: Calling ssort")
      table.ssort(events, quik_predicate)
      print("SCRIPT: Returned from ssort")
      if (table.getn(events) > 0) then
         print("SCRIPT: Calling InsertRow")
         local n = InsertRow(tid, -1)
         print("SCRIPT: Returned from InsertRow")
         print("SCRIPT: Calling SetCell")
         SetCell(tid, n, 1, "First item after sorting in main is: " .. events[1], 0)
         print("SCRIPT: Returned from SetCell")
      end
   end
   print("MAIN: OnQuote end")
end

...
SCRIPT: Calling SetCell
SCRIPT: Returned from SetCell
SCRIPT: script_predicate end
SCRIPT: script_predicate entry
SCRIPT: Calling Clear
SCRIPT: Returned from Clear
SCRIPT: Calling SetWindowCaption
SCRIPT: Returned from SetWindowCaption
SCRIPT: Calling InsertRow

//обработка таких данных из мейна
    for (int i = 0; i < q.getNumberOf("orders"); i++)
    {
        //получаем таблицу, паралельно могут приходить колбеки
        lua::table t = q.getItem("orders", i); 
        main t --> (t.id = 1 , t.balance = 1)        
        //паралельно приходит колбек с такими пар-ми
        поток квика --> OnOrder (t.id = 1, t.balance = 0)

        int mybalance = t.balance
        а тут мы обрабатываем остаток(мейн поток). тут я считал что будет паралельный доступ к данным из 2х потоков. разве нет?
        квик записывает balance заявки а мы его в это время считываем. если квик всеже такое переваривает то что я получу при запросе из таблицы t.balance (0 или 1).
        тобишь обновит квик данные хранящиеся в таблице которую я уже получил или нет?
        
    }