Method thread_function

include/fplus/side_effects.hpp:101–125

private:
    void thread_function()
    {
        auto last_wake_up_time = std::chrono::steady_clock::now();
        auto last_time = last_wake_up_time;
        bool quit = false;
        while (!quit) {
            const auto wake_up_time = last_wake_up_time + std::chrono::microseconds { interval_us_ };
            const auto sleep_time = wake_up_time - std::chrono::steady_clock::now();
            if (stop_mutex_.try_lock_for(sleep_time)) {
                stop_mutex_.unlock();
                quit = true;
            }
            const auto current_time = std::chrono::steady_clock::now();
            const auto elapsed = current_time - last_time;
            last_wake_up_time = wake_up_time;
            last_time = current_time;
            const auto elapsed_us = std::chrono::duration_cast<std::chrono::microseconds>(
                elapsed)
                                        .count();
            try {
                f_(elapsed_us);
            } catch (...) {
            }
        }
    }
    const function f_;
    const std::int64_t interval_us_;
    std::mutex control_mutex_;