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

 if (t.hour < 16) or ((t.hour == 16) and (t.min < 30)) then x = nil end if (t.hour == 16) and (t.min >= 30) and (t.sec == 00) then x = math.max(x or 0, H(index)) end

if (t.hour == 16) and (t.min >= 30) and (t.sec == 00) then x = math.max(x, H(index)) end

local w32 = require "w32-ext"
local ffi = require "cffi"
local SetEvent = w32.SetEvent
local MsgWaitForMultipleObjectsEx = w32.MsgWaitForMultipleObjectsEx
local cb_t = {'EDM4','SiM4','CRM4','CNYRUB_TOM'}
local e_quote, e_stop
local is_run = true

function OnQuote(class_code, sec_code)
  local sent = cb_t[sec_code]
  if sent then
    cb_t[sec_code] = sent + 1
    SetEvent(e_quote)
  end
end
function OnStop()
    is_run = false
    SetEvent(e_stop)
end
function main()
  e_stop = w32.CreateEvent(nil, 0, 0, nil)
  e_quote = w32.CreateEvent(nil, 0, 0, nil)
  local events = ffi.new("HANDLE[2]", {e_quote, e_stop})
  local WAIT_TIMEOUT = w32.WAIT_TIMEOUT
  while is_run do
    local res = MsgWaitForMultipleObjectsEx(2, events, 500, 7423, 0) -- QS_ALLINPUT == 7423
    if res == 1 then break end
      if res == WAIT_TIMEOUT then
         -- по таймауту обработать сообщения, например, о смене foreground окна
      else
         -- обновить стаканы
      end
    end
  end
end

local w32 = require("w32")
local ffi = require "cffi"
ffi.cdef [[
    typedef unsigned int UINT;
    typedef unsigned long DWORD;
    typedef long long LRESULT;
    typedef long long LPARAM;
    typedef unsigned long long WPARAM;
    //typedef void* HWND; // in windows
    typedef intptr_t HWND; // uintptr_t not ok as it appends 'ULL', LPARAM also ok
    typedef intptr_t HANDLE;

    void SetLastError(DWORD);
    //LRESULT SendMessageA(HWND hWnd, UINT Msg, WPARAM wParam, LPARAM lParam);
    HWND GetForegroundWindow();
    DWORD MsgWaitForMultipleObjectsEx(DWORD nCount, const HANDLE *pHandles, DWORD dwMilliseconds, DWORD dwWakeMask, DWORD dwFlags);
]]

w32.SetLastError = ffi.C.SetLastError
w32.GetForegroundWindow = ffi.C.GetForegroundWindow
w32.MsgWaitForMultipleObjectsEx = ffi.C.MsgWaitForMultipleObjectsEx
-- those calls trigger 127 error on first invocation
w32.SetLastError(0)

return w32

local cols, qt
local sent, received, updates = 0, 0, 0
function OnQuote(class_code, sec_code)
  -- отслеживаем котировки только по указанному инструменту
  if (class_code ~= CLASS) or (sec_code ~= SEC) then
    return
  end
  qt = getQuoteLevel2(class_code, sec_code) -- во втором скрипте убрать эту строку
  sent = sent + 1
end

local fmt = string.format
local function updateGrid()
  local s = sent
  if received < s then
    received = s
    fillCols(qt) -- во втором скрипте заменить на fillCols(getQuoteLevel2(CLASS, SEC))
    updates = updates + 1
    grid:BeginUpdate()
    colors = cols.colors -- cols заполняется внутри fillCols, colors используется при рисовании стакана внутри grid.OnPrepareCanvas (не показано тут)
    grid:SetCells(0,1,s) -- число вызовов OnQuote
    grid:SetCells(0,2,updates) -- число отрисовок стакана
    grid:SetCells(0,3,fmt('%.1f%%',(1-updates/s)*100)) -- процент потерь обновлений OnQuote
    local m,ti,mti = VCL.IsMultiThread()
    grid:SetCells(0,4,tostring(m)) -- System.isMultiThread
    grid:SetCells(0,5,tostring(ti)) -- ThreadId
    grid:SetCells(0,6,tostring(mti)) -- MainThreadId
    for c = 0,2 do
      for r,str in pairs(cols[c]) do
        grid:SetCells(c,r,str)
      end
    end
    grid:EndUpdate()
  end
end

is_run = true
function main()
    CreateAndShow()
    while is_run do
        sleep(1)
        updateGrid()
        app:ProcessMessages()
    end
end