Method executeAfter

src-client/ll/api/thread/ClientThreadExecutor.cpp:94–105

void ClientThreadExecutor::execute(std::function<void()> f) const { impl->shared->works.enqueue(std::move(f)); }

std::shared_ptr<data::CancellableCallback>
ClientThreadExecutor::executeAfter(std::function<void()> f, Duration dur) const {
    auto tick = std::chrono::ceil<chrono::ticks>(dur).count();
    if (tick <= 0) {
        execute(std::move(f));
        return nullptr;
    } else {
        auto res = std::make_shared<data::CancellableCallback>(std::move(f));
        impl->shared->scheduledWorks.emplace(impl->shared->frame.load() + tick, res);
        return res;
    }
}

ClientThreadExecutor const& ClientThreadExecutor::getDefault() {
    static ClientThreadExecutor ins("ll_default_client_thread", std::chrono::milliseconds{30}, 16);