dispatcher_executor.hpp

Go to the documentation of this file.

#pragma once
//
// dispatcher_executor.hpp — adapters that bridge IDispatcher to IExecutor
// and IDelayedScheduler. Moved from the Qt demo into the framework so
// every platform host can reuse them without copy-pasting.
//
// Usage:
//   auto exec = std::make_shared<DispatcherExecutor>(my_dispatcher);
//   AsyncCommand<void> cmd{*exec, pool, ...};
//
 
#include "aria/async/executor.hpp"
#include "aria/property_ops.hpp"
#include "aria/runtime/dispatcher.hpp"
 
#include <chrono>
#include <functional>
#include <utility>
 
namespace aria::runtime {

class DispatcherExecutor final : public aria::async::IExecutor {
public:
    explicit DispatcherExecutor(IDispatcher& d) noexcept : d_(d) {}
 
    void post(std::function<void()> fn) override { d_.post(std::move(fn)); }

    [[nodiscard]] aria::SchedulerCaps caps() const noexcept override {
        return aria::SchedulerCaps::Post
             | aria::SchedulerCaps::GraphSafe
             | aria::SchedulerCaps::WorkerSafe
             | aria::SchedulerCaps::MainThread
             | aria::SchedulerCaps::Pumpable;
    }
 
    [[nodiscard]] bool is_main_thread() const noexcept override {
        return d_.is_main_thread();
    }
 
private:
    IDispatcher& d_;
};

class DispatcherScheduler final : public aria::IDelayedScheduler {
public:
    explicit DispatcherScheduler(IDispatcher& d) noexcept : d_(d) {}
 
    void post_after(std::chrono::milliseconds delay,
                    std::function<void()> fn) override {
        d_.post_delayed(delay, std::move(fn));
    }
 
    [[nodiscard]] bool is_main_thread() const noexcept override {
        return d_.is_main_thread();
    }
 
    [[nodiscard]] aria::SchedulerCaps caps() const noexcept override {
        return aria::SchedulerCaps::Post
             | aria::SchedulerCaps::Delay
             | aria::SchedulerCaps::MainThread
             | aria::SchedulerCaps::Pumpable;
    }
 
    void schedule(std::function<void()> fn) override {
        d_.post(std::move(fn));
    }
 
    void schedule_after(std::chrono::milliseconds delay,
                        std::function<void()> fn) override {
        d_.post_delayed(delay, std::move(fn));
    }
 
private:
    IDispatcher& d_;
};
 
}  // namespace aria::runtime