async.hpp

浏览该文件的文档.

#ifndef NEFORCE_CORE_ASYNC_ASYNC_HPP__
#define NEFORCE_CORE_ASYNC_ASYNC_HPP__

 
#include "NeForce/core/async/packaged_task.hpp"
#include "NeForce/core/functional/call_wrapper.hpp"
NEFORCE_BEGIN_NAMESPACE__



template <typename Func, typename... Args>
NEFORCE_NODISCARD future<async_result_t<Func, Args...>> async(launch policy, Func&& function, Args&&... args) {
    using Wrapper = call_wrapper<Func, Args...>;
    using AsyncState = inner::__future_base::async_state_impl<Wrapper, async_result_t<Func, Args...>>;
    using DeferredState = inner::__future_base::deferred_state<Wrapper, async_result_t<Func, Args...>>;
 
    shared_ptr<inner::__future_base::state_base> state;
    if ((policy & launch::async) == launch::async) {
        state = _NEFORCE make_shared<AsyncState>(_NEFORCE forward<Func>(function), _NEFORCE forward<Args>(args)...);
    }
    if (!state) {
        state = _NEFORCE make_shared<DeferredState>(_NEFORCE forward<Func>(function), _NEFORCE forward<Args>(args)...);
    }
    return _NEFORCE future<async_result_t<Func, Args...>>(_NEFORCE move(state));
}

template <typename Func, typename... Args>
NEFORCE_NODISCARD future<async_result_t<Func, Args...>> async(Func&& function, Args&&... args) {
    return _NEFORCE async(launch::async | launch::deferred, _NEFORCE forward<Func>(function),
                          _NEFORCE forward<Args>(args)...);
}
 // Async
 // AsyncComponents
 
NEFORCE_END_NAMESPACE__
#endif // NEFORCE_CORE_ASYNC_ASYNC_HPP__