-/** A continuation attached to a future to be executed when it is ready */
-XBT_PUBLIC_CLASS FutureContinuation {
-public:
- FutureContinuation() {}
-
- // No copy:
- FutureContinuation(FutureContinuation&) = delete;
- FutureContinuation& operator=(FutureContinuation&) = delete;
-
- virtual ~FutureContinuation() {}
- virtual void operator()() = 0;
-};
-
-/** Default implementation of `FutureContinuation`
- *
- * @param T value type of the future
- * @param F type of the wrapped code/callback/continuation
- */
-template<class T, class F>
-class FutureContinuationImpl : public FutureContinuation {
-public:
- FutureContinuationImpl(std::shared_ptr<FutureState<T>> ptr, F callback)
- : ptr_(std::move(ptr)), callback_(std::move(callback)) {}
- ~FutureContinuationImpl() override {}
- void operator()() override
- {
- try {
- callback_(Future<T>(ptr_));
- }
- // Those exceptions are lost.
- // If we want to implement callback chaining, we'll have to catch them and
- // foward them to the next future.
- catch (...) {
- // We could log this.
- }
- }
-private:
- std::shared_ptr<FutureState<T>> ptr_;
- F callback_;
-};
-