Textractor_test/GUI/host/textthread.cc
Akash Mozumdar 3f35c5c230 refactor
2018-08-25 16:02:16 -04:00

64 lines
1.5 KiB
C++

// textthread.cc
// 8/24/2013 jichi
// Branch IHF/TextThread.cpp, rev 133
#include "textthread.h"
#include "const.h"
TextThread::TextThread(ThreadParam tp, DWORD status) :
deletionEvent(CreateEventW(nullptr, FALSE, FALSE, NULL)),
flushThread([&]() { while (WaitForSingleObject(deletionEvent, 100) == WAIT_TIMEOUT) Flush(); }),
timestamp(GetTickCount()),
Output(nullptr),
tp(tp),
status(status)
{}
TextThread::~TextThread()
{
SetEvent(deletionEvent);
flushThread.join();
CloseHandle(deletionEvent);
}
std::wstring TextThread::GetStore()
{
LOCK ttLock(ttMutex);
return storage;
}
void TextThread::Flush()
{
LOCK ttLock(ttMutex);
if (timestamp - GetTickCount() < 250 || buffer.size() == 0) return; // TODO: let user change delay before sentence is flushed
std::wstring sentence;
if (status & USING_UNICODE)
{
sentence = std::wstring((wchar_t*)buffer.data(), buffer.size() / 2);
}
else
{
wchar_t* converted = new wchar_t[buffer.size()];
sentence = std::wstring(converted, MultiByteToWideChar(status & USING_UTF8 ? CP_UTF8 : 932, 0, buffer.data(), buffer.size(), converted, buffer.size()));
delete[] converted;
}
AddSentence(sentence);
buffer.clear();
}
void TextThread::AddSentence(std::wstring sentence)
{
LOCK ttLock(ttMutex);
if (Output) sentence = Output(this, sentence);
storage.append(sentence);
}
void TextThread::AddText(const BYTE *con, int len)
{
LOCK ttLock(ttMutex);
buffer.insert(buffer.end(), con, con + len);
timestamp = GetTickCount();
}
// EOF