Method loop_until_impl

source/executors/manual_executor.cpp:83–128

}

size_t manual_executor::loop_until_impl(size_t max_count, std::chrono::time_point<std::chrono::system_clock> deadline) {
    if (max_count == 0) {
        return 0;
    }

    size_t executed = 0;
    deadline += std::chrono::milliseconds(1);

    while (true) {
        if (executed == max_count) {
            break;
        }

        const auto now = std::chrono::system_clock::now();
        if (now >= deadline) {
            break;
        }

        std::unique_lock<decltype(m_lock)> lock(m_lock);
        const auto found_task = m_condition.wait_until(lock, deadline, [this] {
            return !m_tasks.empty() || m_abort;
        });

        if (m_abort) {
            break;
        }

        if (!found_task) {
            break;
        }

        assert(!m_tasks.empty());
        auto task = std::move(m_tasks.front());
        m_tasks.pop_front();
        lock.unlock();

        task();
        ++executed;
    }

    if (shutdown_requested()) {
        details::throw_runtime_shutdown_exception(name);
    }

    return executed;
}

void manual_executor::wait_for_tasks_impl(size_t count) {
    if (count == 0) {