executor.hpp

浏览该文件的文档.

#ifndef NEFORCE_CORE_ASYNC_EXECUTOR_HPP__
#define NEFORCE_CORE_ASYNC_EXECUTOR_HPP__

 
#include "NeForce/core/functional/function.hpp"
#include "NeForce/core/memory/shared_ptr.hpp"
NEFORCE_BEGIN_NAMESPACE__



class executor {
public:
    using handler_type = function<void()>;

    struct executor_base {
        virtual ~executor_base() = default;
        virtual void execute(handler_type handler) = 0;
    };
 
private:
    shared_ptr<executor_base> exec_;
 
public:
    executor() = default;

    template <typename Exec, enable_if_t<!is_same_v<decay_t<Exec>, executor>, int> = 0>
    executor(Exec exec) {
        struct wrapper final : executor_base {
            Exec exec_;
            explicit wrapper(Exec e) :
            exec_(move(e)) {}
            void execute(handler_type handler) override { exec_.execute(move(handler)); }
        };
        exec_ = _NEFORCE make_shared<wrapper>(_NEFORCE move(exec));
    }

    void execute(handler_type handler) const {
        if (exec_) {
            exec_->execute(move(handler));
        }
    }

    void post(handler_type handler) const { execute(move(handler)); }

    explicit operator bool() const noexcept { return static_cast<bool>(exec_); }

    NEFORCE_NODISCARD bool operator==(const executor& other) const noexcept { return exec_ == other.exec_; }

    NEFORCE_NODISCARD bool operator!=(const executor& other) const noexcept { return exec_ != other.exec_; }
};

template <typename Executor>
void post(Executor& ex, function<void()> handler) {
    ex.execute(move(handler));
}
 // Executor
 // AsyncComponents
 
NEFORCE_END_NAMESPACE__
#endif // NEFORCE_CORE_ASYNC_EXECUTOR_HPP__