X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/611d822b02f836d7abe031cced6adc4281ef4356..d37b22379fc9b7e760482d6edc10b645d9862db6:/include/xbt/future.hpp diff --git a/include/xbt/future.hpp b/include/xbt/future.hpp index 3c1f761ab7..be488ed9d7 100644 --- a/include/xbt/future.hpp +++ b/include/xbt/future.hpp @@ -199,9 +199,17 @@ public: * @param code What we want to do * @param promise Where to want to store the result */ -template -auto fulfillPromise(R& promise, F&& code) --> decltype(promise.set_value(code())) +template auto fulfill_promise(R& promise, F&& code) -> decltype(promise.set_value(code())) +{ + try { + promise.set_value(std::forward(code)()); + } catch (...) { + promise.set_exception(std::current_exception()); + } +} +template +XBT_ATTRIB_DEPRECATED_v323("Please use xbt::fulfill_promise()") auto fulfillPromise(R& promise, F&& code) + -> decltype(promise.set_value(code())) { try { promise.set_value(std::forward(code)()); @@ -211,9 +219,18 @@ auto fulfillPromise(R& promise, F&& code) } } -template -auto fulfillPromise(P& promise, F&& code) --> decltype(promise.set_value()) +template auto fulfill_promise(P& promise, F&& code) -> decltype(promise.set_value()) +{ + try { + std::forward(code)(); + promise.set_value(); + } catch (...) { + promise.set_exception(std::current_exception()); + } +} +template +XBT_ATTRIB_DEPRECATED_v323("Please use xbt::fulfill_promise()") auto fulfillPromise(P& promise, F&& code) + -> decltype(promise.set_value()) { try { std::forward(code)(); @@ -238,10 +255,14 @@ auto fulfillPromise(P& promise, F&& code) * @param promise output (a valid future or a result) * @param future input (a ready/waitable future or a valid result) */ -template inline -void setPromise(P& promise, F&& future) +template inline void set_promise(P& promise, F&& future) +{ + fulfill_promise(promise, [&] { return std::forward(future).get(); }); +} +template +inline XBT_ATTRIB_DEPRECATED_v323("Please use xbt::set_promise()") void setPromise(P& promise, F&& future) { - fulfillPromise(promise, [&]{ return std::forward(future).get(); }); + fulfill_promise(promise, [&] { return std::forward(future).get(); }); } }