X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/3388e09cbb920fc3b904327f3b254f794e231ed1..4f2e9b5f5dd58b3493e5ce66014e52c76f68a777:/include/simgrid/kernel/future.hpp diff --git a/include/simgrid/kernel/future.hpp b/include/simgrid/kernel/future.hpp index 6adfe664dd..693203aa79 100644 --- a/include/simgrid/kernel/future.hpp +++ b/include/simgrid/kernel/future.hpp @@ -204,23 +204,31 @@ public: } }; -template -void bindPromise(Promise promise, Future future) +template void bind_promise(Promise promise, Future future) { class PromiseBinder { public: explicit PromiseBinder(Promise promise) : promise_(std::move(promise)) {} - void operator()(Future future) - { - simgrid::xbt::setPromise(promise_, future); - } + void operator()(Future future) { simgrid::xbt::set_promise(promise_, future); } + private: Promise promise_; }; 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 * @@ -334,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) @@ -350,10 +356,17 @@ public: [](Promise promise, std::shared_ptr> state, F continuation) { // ...set the new future value by running the continuation. Future future(std::move(state)); - simgrid::xbt::fulfillPromise(promise, [&] { return continuation(std::move(future)); }); + 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 @@ -370,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) */ @@ -381,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 @@ -407,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); }