| 117 | void ThreadPoolExecutor::destroy() { impl.reset(); } |
| 118 | |
| 119 | void ThreadPoolExecutor::execute(std::function<void()> f) const { |
| 120 | impl->tasks.enqueue(std::move(f)); |
| 121 | impl->taskCount.release(); |
| 122 | } |
| 123 | std::shared_ptr<data::CancellableCallback> |
| 124 | ThreadPoolExecutor::executeAfter(std::function<void()> f, Duration dur) const { |
| 125 | if (dur <= Duration{0}) { |
no test coverage detected