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

#include <cstdio>
#include <intrin.h>
#include <process.h>
#include <Windows.h>

static const unsigned int NTHRD = 64;
static const unsigned int NITER = 10000000;
static volatile long cnt[NTHRD];

static unsigned int __stdcall RawLoopThread(void * pvoid)
{
   volatile long * pcnt = cnt + reinterpret_cast<unsigned int>(pvoid);
   *pcnt = 0;
   for(unsigned int n = 0; n < NITER; ++n)
      *pcnt = *pcnt + 1;
   return *pcnt;
}

static unsigned int __stdcall InterlockedLoopThread(void * pvoid)
{
   volatile long * pcnt = cnt + reinterpret_cast<unsigned int>(pvoid);
   *pcnt = 0;
   for(unsigned int n = 0; n < NITER; ++n)
      _InterlockedIncrement(pcnt);
   return *pcnt;
}

static void MeasureLoop(unsigned int (__stdcall * pfn)(void *), const char * name)
{
   unsigned long long t = ::GetTickCount64();
   HANDLE threads[NTHRD] = { 0 };
   for(unsigned int n = 0; n < NTHRD; ++n)
   {
      unsigned int tid;
      threads[n] = reinterpret_cast<HANDLE>(_beginthreadex(nullptr, 0,
         pfn, reinterpret_cast<void *>(n), CREATE_SUSPENDED, &tid));
   }
   for(unsigned int n = 0; n < NTHRD; ++n)
      ::ResumeThread(threads[n]);
   ::WaitForMultipleObjects(NTHRD, threads, TRUE, INFINITE);
   t = ::GetTickCount64() - t;
   for(unsigned int n = 0; n < NTHRD; ++n)
      ::CloseHandle(threads[n]);
   printf("  %s:\n    %0.9f seconds\n    %0.9f microseconds per iteration\n",
      name, t / 1000.0, t * 1000.0 / NITER);
}

void main(void)
{
   printf("Performance:\n");
   ::MeasureLoop(::RawLoopThread, "RawLoopThread");
   ::MeasureLoop(::InterlockedLoopThread, "InterlockedLoopThread");
   printf("Press ENTER to exit\n");
   getchar();
}

class Order
{
    void SendTransaction(...);
    virtual void OnTransReply(...);
    virtual void OnOrder(...);
};

class Order
{
    virtual void OnOrder(...);
};

class Transaction
{
    SendTransaction(...);
    virtual void OnTransReply(...);
};

io.open("\\\\.\\PIPE\\MySuperPuperServer", "wb")

int callScriptOnAllTrade(lua_State * s)
{
   lua_checkstack(s, 1);
   int top = lua_gettop(s);
   lua_getglobal(s, "OnAllTrade");
   pushOnAllTradeArgument(s);
   int ret = doSafeLuaCall(s); // lua_pcall + SEH frame
   if(!ret)
      processScriptCallbackError(s);
   lua_settop(s, top);
   return ret;
}

static int aux_close (lua_State *L) {
  LStream *p = tolstream(L);
  volatile lua_CFunction cf = p->closef;
  p->closef = NULL;  /* mark stream as closed */
  return (*cf)(L);  /* close it */
}

static int f_close (lua_State *L) {
  tofile(L);  /* make sure argument is an open stream */
  return aux_close(L);
}

static int io_fclose (lua_State *L) {
  LStream *p = tolstream(L);
  int res = fclose(p->f);
  return luaL_fileresult(L, (res == 0), NULL);
}

int qOnAllTrade(lua_State * scb)
{
  return 0;
}

int qMain(lua_State * sm)
{
  while(something)
  {
    WaitForSingleObject(hSyncObject, INFINITE);
    DoSomething(sm);
  }
  return 0;
}