Method ServerThreadExecutor

src/ll/api/thread/ServerThreadExecutor.cpp:62–87

    event::ListenerPtr          worker;
};
ServerThreadExecutor::ServerThreadExecutor(std::string name, Duration maxOnceDuration, size_t checkPack)
: Executor(std::move(name)),
  impl(std::make_unique<Impl>(std::make_shared<Impl::SharedImpl>())) {
    impl->worker = event::EventBus::getInstance().emplaceListener<event::ServerLevelTickEvent>(
        [name = getName(), maxOnceDuration, checkPack, weak = std::weak_ptr{impl->shared}](auto&&) {
            auto impl = weak.lock();
            if (!impl) {
                return;
            }
            auto begin = Clock::now();
            impl->update([&](auto& f, size_t i) {
                try {
                    f();
                } catch (...) {
                    getLogger().error("Error in {}:", name);
                    error_utils::printCurrentException(getLogger());
                }
                if (i % checkPack == 0 && Clock::now() - begin > maxOnceDuration) {
                    return false;
                }
                return true;
            });
        },
        event::EventPriority::Low
    );
}
ServerThreadExecutor::~ServerThreadExecutor() {
    event::EventBus::getInstance().removeListener<event::ServerLevelTickEvent>(impl->worker);
}