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

         if (!ReadFile(handle, readBuffer, BUFFER_SIZE, &bytesRead, &overlapped)) { // асинхронное чтение, возврат по ERROR_IO_PENDING - надо ждать завершения
            DWORD error = GetLastError();
            if (error == ERROR_IO_PENDING) {
               message(threadL, "Ждём записи");
               DWORD status = WaitForSingleObject(handle, 1000); // ниже проверки на успех или обрыв, обычно читает
...
processCommand(threadL, readBuffer, bytesRead); // тут всякие квик-луа запросы
...
if (!WriteFile(handle, responseBuffer, responseLength, &written, &overlapped)) {
...// тут проверка на обрыв и дисконнект - обычно проходит мимо
}

// дальше идём на ReadFile, там обычно ловим IO_PENDING и входим в WaitForSingleObject

int main(lua_State *L){
   //// тут мы создаём новый state для отдельного потока
   //// см https://kristianrumberg.wordpress.com/2010/11/21/135/
   //// https://stackoverflow.com/questions/17817452/lua-5-2-2-broken-threading-system/17818481#17818481
   //// https://forum.quik.ru/messages/forum10/message10476/topic212/#message10476

   //lua_gc(L, LUA_GCSTOP, 0);
   //lua_State *tL = lua_newthread(L); // здесь tl кладётся в т.ч. стек L
   //int thread_L_ref = luaL_ref(L, LUA_REGISTRYINDEX); // создаётся ссылка на объект на верхушке стека
   //lua_pushvalue(L, -1);
   //lua_gc(L, LUA_GCRESTART, 0);

   //stopped = false;
   //std::thread pipeThread(pipe_thread, tL);
   //lua_function<lua_Number> lua_Sleep(L, "sleep");

   //while (!stopped) {
   //   lua_Sleep( 1000 );
   //}

   //pipeThread.join();
   //lua_unref(L, thread_L_ref);
   pipe_thread(L);
   message(L, "QPIPE: скрипт остановлен");

   return 0;
}

int testS(lua_State *L, LPCSTR cl, LPCSTR sec, double interval){
      lua_getglobal(L, "CreateDataSource");
      lua_pushstring(L, cl);
      lua_pushstring(L, sec);
      lua_pushnumber(L, interval);

      message(L, "before create datasource");
      if (lua_pcall(L, 3, 2, 0)!=0){
         message(L, "pcall unsucceeded");
         message(L, lua_tostring(L, -2));
      } else {
         message(L, "pcall succeeded");
      }
      message(L, "after create datasource");
      char x[10];
      itoa(lua_gettop(L), x, 10);
      message(L, x);
      if (lua_isnil(L, -2)){
         message(L, "ds is nil");
         message(L, lua_tostring(L, -1));
      }
      lua_remove(L, -1);
      // -2 = массив
      message(L, lua_typename(L, lua_type(L, -1)));
      message(L, lua_tostring(L, -1));
      return 1;
}

int testDS(lua_State *L){
   testS(L, "SPBFUT", "Si-6.16", 1);
   return 1;
}

function bestBidAndOffer(cls, sec)
   local ql2 = getQuoteLevel2(cls, sec)
--   message("" .. ql2.bid_count, 1)
        if ql2 ~= nil then
           return ql2.bid[ql2.bid_count+0].price, ql2.offer[1].price
        end
        return nil
end