Method executeAfter

src/ll/api/thread/ThreadPoolExecutor.cpp:123–135

    impl->taskCount.release();
}
std::shared_ptr<data::CancellableCallback>
ThreadPoolExecutor::executeAfter(std::function<void()> f, Duration dur) const {
    if (dur <= Duration{0}) {
        execute(std::move(f));
        return nullptr;
    } else {
        auto& worker = impl->getScheduledWorker(*this);
        auto  res    = std::make_shared<data::CancellableCallback>(std::move(f));
        worker.works.emplace(Clock::now() + dur, res);
        worker.sleeper.interrupt();
        return res;
    }
}
ThreadPoolExecutor const& ThreadPoolExecutor::getDefault() {
    static ThreadPoolExecutor ins("ll_default_thread_pool", std::max((int)std::thread::hardware_concurrency() - 2, 2));
    return ins;