2016-01-06 00:01:17 +09:00
|
|
|
#pragma once
|
|
|
|
|
|
|
|
// textthread.h
|
|
|
|
// 8/23/2013 jichi
|
|
|
|
// Branch: ITH/TextThread.h, rev 120
|
|
|
|
|
2018-08-22 12:24:55 -04:00
|
|
|
#include "common.h"
|
2018-08-24 12:50:20 -04:00
|
|
|
#include "types.h"
|
2016-01-06 00:01:17 +09:00
|
|
|
|
2018-07-18 23:40:44 -04:00
|
|
|
class TextThread
|
2016-01-06 00:01:17 +09:00
|
|
|
{
|
2018-08-23 11:53:23 -04:00
|
|
|
typedef std::function<std::wstring(TextThread*, std::wstring)> ThreadOutputCallback;
|
2018-10-04 19:52:16 -04:00
|
|
|
|
2016-01-06 00:01:17 +09:00
|
|
|
public:
|
2018-08-23 11:53:23 -04:00
|
|
|
TextThread(ThreadParam tp, DWORD status);
|
2018-08-24 12:50:20 -04:00
|
|
|
~TextThread();
|
2016-01-06 00:01:17 +09:00
|
|
|
|
2018-08-24 12:50:20 -04:00
|
|
|
std::wstring GetStore();
|
2018-09-22 17:13:06 -04:00
|
|
|
void AddText(const BYTE* data, int len);
|
|
|
|
void AddSentence(std::wstring sentence);
|
2018-08-21 22:43:30 -04:00
|
|
|
void RegisterOutputCallBack(ThreadOutputCallback cb) { Output = cb; }
|
2016-01-06 00:01:17 +09:00
|
|
|
|
2018-09-22 17:13:06 -04:00
|
|
|
const int64_t handle;
|
2018-09-20 22:32:47 -04:00
|
|
|
const std::wstring name;
|
|
|
|
const ThreadParam tp;
|
|
|
|
|
2018-10-04 23:23:57 -04:00
|
|
|
inline static int(*Prefilter)(wchar_t*, const wchar_t*) = nullptr;
|
2018-09-22 17:13:06 -04:00
|
|
|
inline static int FlushDelay = 250; // flush every 250ms by default
|
2018-10-04 22:10:27 -04:00
|
|
|
inline static int MaxBufferSize = 200;
|
2018-09-22 17:13:06 -04:00
|
|
|
inline static int ThreadCounter = 0;
|
2018-09-21 21:27:59 -04:00
|
|
|
|
2016-01-06 00:01:17 +09:00
|
|
|
private:
|
2018-08-25 16:02:16 -04:00
|
|
|
void Flush();
|
2018-08-21 22:43:30 -04:00
|
|
|
|
2018-10-04 19:52:16 -04:00
|
|
|
std::wstring buffer;
|
2018-07-19 23:22:55 -04:00
|
|
|
std::wstring storage;
|
2018-08-28 16:25:08 -04:00
|
|
|
std::recursive_mutex ttMutex;
|
2018-10-04 22:10:27 -04:00
|
|
|
|
|
|
|
HANDLE deletionEvent = CreateEventW(nullptr, FALSE, FALSE, NULL);
|
|
|
|
std::thread flushThread = std::thread([&] { while (WaitForSingleObject(deletionEvent, 10) == WAIT_TIMEOUT) Flush(); });
|
|
|
|
DWORD timestamp = GetTickCount();
|
2018-08-24 11:32:10 -04:00
|
|
|
|
2018-08-21 23:56:16 -04:00
|
|
|
ThreadOutputCallback Output;
|
2018-07-19 23:22:55 -04:00
|
|
|
DWORD status;
|
2016-01-06 00:01:17 +09:00
|
|
|
};
|
|
|
|
|
|
|
|
// EOF
|