Method executeAfter

src/ll/api/thread/ServerThreadExecutor.cpp:93–104

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

std::shared_ptr<data::CancellableCallback>
ServerThreadExecutor::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;
    }
}

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