task_completion_source.hpp

Go to the documentation of this file.

#pragma once
#include "task_result.hpp"
#include "../cancellation_token_source.hpp"
#include "../../new_ptr.hpp"
#include "../../ptr.hpp"

namespace xtd {
  namespace threading {
    namespace tasks {
      template<class result_t>
      class task_completion_source : public xtd::object {
      public:

        task_completion_source() : data_ {xtd::new_ptr<data>([this] {
          //if (data_->task.token().is_cancellation_requested()) throw task_canceled_exception {};
          if (data_->exception != null) throw *data_->exception;
          return data_->result;
        })} {}
        
        
        auto task() const noexcept -> const xtd::threading::tasks::task<result_t>& {return data_->task;}
        
        
        auto set_canceled() -> void {
          data_->cancellation.cancel();
          data_->task.start();
        }
 
        template<class exception_t>
        auto set_exception(const exception_t& exception) -> void {
          data_->exception = xtd::ptr<xtd::exception> {exception.template memberwise_clone<exception_t>().release()};
          *data_->exception = exception;
          data_->task.start();
        }
 
        auto set_result(result_t&& result) -> void {
          data_->result = std::forward<result_t>(result);
          data_->task.start();
        }
        
      private:
        struct data {
          template<typename func_t>
          data(func_t func) {task = {func, cancellation.token()};}
          xtd::threading::cancellation_token_source cancellation;
          result_t result;
          xtd::ptr<xtd::exception> exception;
          xtd::threading::tasks::task<result_t> task;
        };
        xtd::ptr<data> data_;
      };
    }
  }
}