X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/3bd0ffd5e6dd32ddf61c69456b490f2aa9f2517b..4f2e9b5f5dd58b3493e5ce66014e52c76f68a777:/include/simgrid/kernel/future.hpp diff --git a/include/simgrid/kernel/future.hpp b/include/simgrid/kernel/future.hpp index bc45b509b5..693203aa79 100644 --- a/include/simgrid/kernel/future.hpp +++ b/include/simgrid/kernel/future.hpp @@ -204,8 +204,7 @@ public: } }; -template -void bindPromise(Promise promise, Future future) +template void bind_promise(Promise promise, Future future) { class PromiseBinder { public: @@ -218,7 +217,18 @@ void bindPromise(Promise promise, Future future) future.then_(PromiseBinder(std::move(promise))); } -template Future unwrapFuture(Future> future); +template Future unwrap_future(Future> future); + +template +XBT_ATTRIB_DEPRECATED_v323("Please use bind_promise") void bindPromise(Promise promise, Future future) +{ + bind_promise(promise, future); +} +template +XBT_ATTRIB_DEPRECATED_v323("Please use unwrap_future") Future unwrapFuture(Future> future) +{ + unwrap_future(future); +} /** Result of some (probably) asynchronous operation in the SimGrid kernel * @@ -332,9 +342,7 @@ public: * * This version never does future unwrapping. */ - template - auto thenNoUnwrap(F continuation) - -> Future + template auto then_no_unwrap(F continuation) -> Future { typedef decltype(continuation(std::move(*this))) R; if (state_ == nullptr) @@ -351,7 +359,14 @@ public: simgrid::xbt::fulfill_promise(promise, [&] { return continuation(std::move(future)); }); }, std::move(promise), state, std::move(continuation))); - return std::move(future); + return future; + } + + template + XBT_ATTRIB_DEPRECATED_v323("Please use then_no_unwrap") auto thenNoUnwrap(F continuation) + -> Future + { + then_no_unwrap(continuation); } /** Attach a continuation to this future @@ -368,7 +383,7 @@ public: auto then(F continuation) -> typename std::enable_if::value, Future>::type { - return this->thenNoUnwrap(std::move(continuation)); + return this->then_no_unwrap(std::move(continuation)); } /** Attach a continuation to this future (future chaining) */ @@ -379,7 +394,7 @@ public: decltype(continuation(std::move(*this))) >::type { - return unwrapFuture(this->thenNoUnwap(std::move(continuation))); + return unwrap_future(this->then_no_unwrap(std::move(continuation))); } /** Get the value from the future @@ -405,12 +420,11 @@ private: std::shared_ptr> state_; }; -template -Future unwrapFuture(Future> future) +template Future unwrap_future(Future> future) { Promise promise; Future result = promise.get_future(); - bindPromise(std::move(promise), std::move(future)); + bind_promise(std::move(promise), std::move(future)); return std::move(result); }