| 1 | #pragma once |
| 2 | |
| 3 | #include <mbgl/util/optional.hpp> |
| 4 | |
| 5 | #include <future> |
| 6 | #include <utility> |
| 7 | |
| 8 | namespace mbgl { |
| 9 | |
| 10 | // A movable type-erasing function wrapper. This allows to store arbitrary invokable |
| 11 | // things (like std::function<>, or the result of a movable-only std::bind()) in the queue. |
| 12 | // Source: http://stackoverflow.com/a/29642072/331379 |
| 13 | class Message { |
| 14 | public: |
| 15 | virtual ~Message() = default; |
| 16 | virtual void operator()() = 0; |
| 17 | }; |
| 18 | |
| 19 | template <class Object, class MemberFn, class ArgsTuple> |
| 20 | class MessageImpl : public Message { |
| 21 | public: |
| 22 | MessageImpl(Object& object_, MemberFn memberFn_, ArgsTuple argsTuple_) |
| 23 | : object(object_), |
| 24 | memberFn(memberFn_), |
| 25 | argsTuple(std::move(argsTuple_)) { |
| 26 | } |
| 27 | |
| 28 | void operator()() override { |
| 29 | invoke(std::make_index_sequence<std::tuple_size<ArgsTuple>::value>()); |
| 30 | } |
| 31 | |
| 32 | template <std::size_t... I> |
| 33 | void invoke(std::index_sequence<I...>) { |
| 34 | (object.*memberFn)(std::move(std::get<I>(argsTuple))...); |
| 35 | } |
| 36 | |
| 37 | Object& object; |
| 38 | MemberFn memberFn; |
| 39 | ArgsTuple argsTuple; |
| 40 | }; |
| 41 | |
| 42 | template <class ResultType, class Object, class MemberFn, class ArgsTuple> |
| 43 | class AskMessageImpl : public Message { |
| 44 | public: |
| 45 | AskMessageImpl(std::promise<ResultType> promise_, Object& object_, MemberFn memberFn_, ArgsTuple argsTuple_) |
| 46 | : object(object_), |
| 47 | memberFn(memberFn_), |
| 48 | argsTuple(std::move(argsTuple_)), |
| 49 | promise(std::move(promise_)) { |
| 50 | } |
| 51 | |
| 52 | void operator()() override { |
| 53 | promise.set_value(ask(std::make_index_sequence<std::tuple_size<ArgsTuple>::value>())); |
| 54 | } |
| 55 | |
| 56 | template <std::size_t... I> |
| 57 | ResultType ask(std::index_sequence<I...>) { |
| 58 | return (object.*memberFn)(std::move(std::get<I>(argsTuple))...); |
| 59 | } |
| 60 | |
| 61 | Object& object; |
| 62 | MemberFn memberFn; |
| 63 | ArgsTuple argsTuple; |
| 64 | std::promise<ResultType> promise; |
| 65 | }; |
| 66 | |
| 67 | template <class Object, class MemberFn, class ArgsTuple> |
| 68 | class AskMessageImpl<void, Object, MemberFn, ArgsTuple> : public Message { |
| 69 | public: |
| 70 | AskMessageImpl(std::promise<void> promise_, Object& object_, MemberFn memberFn_, ArgsTuple argsTuple_) |
| 71 | : object(object_), |
| 72 | memberFn(memberFn_), |
| 73 | argsTuple(std::move(argsTuple_)), |
| 74 | promise(std::move(promise_)) { |
| 75 | } |
| 76 | |
| 77 | void operator()() override { |
| 78 | ask(std::make_index_sequence<std::tuple_size<ArgsTuple>::value>()); |
| 79 | promise.set_value(); |
| 80 | } |
| 81 | |
| 82 | template <std::size_t... I> |
| 83 | void ask(std::index_sequence<I...>) { |
| 84 | (object.*memberFn)(std::move(std::get<I>(argsTuple))...); |
| 85 | } |
| 86 | |
| 87 | Object& object; |
| 88 | MemberFn memberFn; |
| 89 | ArgsTuple argsTuple; |
| 90 | std::promise<void> promise; |
| 91 | }; |
| 92 | |
| 93 | namespace actor { |
| 94 | |
| 95 | template <class Object, class MemberFn, class... Args> |
| 96 | std::unique_ptr<Message> makeMessage(Object& object, MemberFn memberFn, Args&&... args) { |
| 97 | auto tuple = std::make_tuple(std::forward<Args>(args)...); |
| 98 | return std::make_unique<MessageImpl<Object, MemberFn, decltype(tuple)>>(object, memberFn, std::move(tuple)); |
| 99 | } |
| 100 | |
| 101 | template <class ResultType, class Object, class MemberFn, class... Args> |
| 102 | std::unique_ptr<Message> makeMessage(std::promise<ResultType>&& promise, Object& object, MemberFn memberFn, Args&&... args) { |
| 103 | auto tuple = std::make_tuple(std::forward<Args>(args)...); |
| 104 | return std::make_unique<AskMessageImpl<ResultType, Object, MemberFn, decltype(tuple)>>(std::move(promise), object, memberFn, std::move(tuple)); |
| 105 | } |
| 106 | |
| 107 | } // namespace actor |
| 108 | } // namespace mbgl |
| 109 | |