| 16 | } // namespace |
| 17 | |
| 18 | DelayedThreadPool::DelayedThreadPool(size_t threadsCount /* = 1 */, Exit e /* = Exit::SkipPending */) |
| 19 | : m_exit(e) |
| 20 | , m_immediateLastId(kImmediateMaxId) |
| 21 | , m_delayedLastId(kDelayedMaxId) |
| 22 | { |
| 23 | for (size_t i = 0; i < threadsCount; ++i) |
| 24 | m_threads.emplace_back(threads::SimpleThread(&DelayedThreadPool::ProcessTasks, this)); |
| 25 | } |
| 26 | |
| 27 | DelayedThreadPool::~DelayedThreadPool() |
| 28 | { |
nothing calls this directly
no test coverage detected