44 lines
761 B
C++
44 lines
761 B
C++
#include "stdafx.h"
|
|
#include "AutoThread.h"
|
|
|
|
using namespace Sia::Api;
|
|
|
|
CAutoThread::CAutoThread(const CSiaCurl& siaCurl) :
|
|
_siaCurl(siaCurl.GetHostConfig()),
|
|
_stopEvent(::CreateEvent(nullptr, FALSE, FALSE, nullptr))
|
|
{
|
|
}
|
|
|
|
CAutoThread::~CAutoThread()
|
|
{
|
|
StopAutoThread();
|
|
::CloseHandle(_stopEvent);
|
|
}
|
|
|
|
void CAutoThread::StartAutoThread()
|
|
{
|
|
std::lock_guard<std::mutex> l(_startStopMutex);
|
|
if (!_thread)
|
|
{
|
|
_thread.reset(new std::thread([this]() {
|
|
do
|
|
{
|
|
AutoThreadCallback(_siaCurl);
|
|
} while (::WaitForSingleObject(_stopEvent, 2000) == WAIT_TIMEOUT);
|
|
}));
|
|
}
|
|
}
|
|
|
|
void CAutoThread::StopAutoThread()
|
|
{
|
|
std::lock_guard<std::mutex> l(_startStopMutex);
|
|
if (_thread)
|
|
{
|
|
::SetEvent(_stopEvent);
|
|
_thread->join();
|
|
_thread.reset(nullptr);
|
|
}
|
|
}
|
|
|
|
|