18ed8cc485
Batch #12020 by Yommy: 3 byte-identical, 0 confirmed by peer review. - fn_07584 NAsyncWorkThread::Receive: byte-identical - fn_07583 NAsyncWorkThread::RequestStop: byte-identical - fn_07613 NMessageMgr::Send: byte-identical Merged automatically: every function is byte-identical to the original.
33 lines
1 KiB
C++
33 lines
1 KiB
C++
#ifndef RAGNAROK_SOURCE_UTILITY_ASYNC_NASYNCWORKTHREAD_H
|
|
#define RAGNAROK_SOURCE_UTILITY_ASYNC_NASYNCWORKTHREAD_H
|
|
|
|
#include "Utility/Async/NAsyncWorkQueue.h"
|
|
#include "Utility/Async/NMessageMgr.h"
|
|
#include "Utility/Async/NMessageQueue.h"
|
|
#include "Utility/Async/NObject.h"
|
|
#include "Utility/Threading/NThread.h"
|
|
|
|
class NAsyncWorkThread : public NObject, public NInter, public NThread {
|
|
friend class NAsyncWorkMgr;
|
|
|
|
public:
|
|
NAsyncWorkThread(NAsyncWorkRequestQueue* requests, NAsyncWorkResponseQueue* responses);
|
|
~NAsyncWorkThread() override;
|
|
void Receive(std::uint32_t argumentLow, std::uint32_t argumentHigh, std::uint32_t id) override;
|
|
unsigned Run() override;
|
|
void RequestStop() override;
|
|
bool Start();
|
|
void Stop();
|
|
|
|
protected:
|
|
/* 0038 */ bool m_registered;
|
|
/* 003C */ NMessageQueue m_messages;
|
|
/* 0074 */ NAsyncWorkRequestQueue* m_requests;
|
|
/* 0078 */ NAsyncWorkResponseQueue* m_responses;
|
|
};
|
|
|
|
#if defined(_WIN32) && !defined(_WIN64)
|
|
static_assert(sizeof(NAsyncWorkThread) == 124);
|
|
#endif
|
|
|
|
#endif
|