RuntimeScheduler.h

Go to the documentation of this file.

#pragma once
 
#include <QtCore/QObject>
 
#include <chrono>
#include <functional>
 
class RuntimeScheduler : public QObject
{
    Q_OBJECT
public:
    using TaskId = quint64;
    using Callback = std::function<void()>;
    static constexpr auto MAX_DELAY =
        std::chrono::duration_cast<std::chrono::microseconds>((std::chrono::nanoseconds::max) ());
 
    explicit RuntimeScheduler(QObject* parent = nullptr);
    ~RuntimeScheduler() override;
 
    [[nodiscard]] static RuntimeScheduler* orDefault(RuntimeScheduler* scheduler, QObject* owner);
 
    virtual quint64 nowUs() const = 0;
 
    qint64 nowMs() const { return static_cast<qint64>(nowUs() / 1000); }
 
    virtual TaskId schedule(QObject* context, std::chrono::microseconds delay, Callback callback) = 0;
    virtual void cancel(TaskId task) = 0;
 
protected:
    bool _canSchedule(QObject* context, std::chrono::microseconds delay, const Callback& callback) const;
    bool _isCurrentThread() const;
};