| 16 | boost::thread_specific_ptr<WorkQueue *> l_ThreadWorkQueue; |
| 17 | |
| 18 | WorkQueue::WorkQueue(size_t maxItems, int threadCount, LogSeverity statsLogLevel) |
| 19 | : m_ID(m_NextID++), m_ThreadCount(threadCount), m_MaxItems(maxItems), |
| 20 | m_StatsLogLevel(statsLogLevel), m_TaskStats(15 * 60) |
| 21 | { |
| 22 | /* Initialize logger. */ |
| 23 | m_StatusTimerTimeout = Utility::GetTime(); |
| 24 | |
| 25 | m_StatusTimer = Timer::Create(); |
| 26 | m_StatusTimer->SetInterval(10); |
| 27 | m_StatusTimer->OnTimerExpired.connect([this](const Timer * const&) { StatusTimerHandler(); }); |
| 28 | m_StatusTimer->Start(); |
| 29 | } |
| 30 | |
| 31 | WorkQueue::~WorkQueue() |
| 32 | { |
nothing calls this directly
no test coverage detected