parallel.hpp

Go to the documentation of this file.

#pragma once
#include "task_factory.hpp"
#include "../../collections/generic/list.hpp"
#include "../../array.hpp"
#include "../../static.hpp"

namespace xtd {
  namespace threading {
    namespace tasks {
      class parallel static_ {
      public:
        static auto invoke(xtd::array<xtd::action<>>&& actions) -> void {
          task<>::wait_all(invoke_async(actions));
        }

        template<typename collection_t>
        static auto invoke(collection_t&& actions) -> void {
          task<>::wait_all(invoke_async(actions));
        }

        template<typename ...args_t>
        static auto invoke(args_t&&... args) -> void {invoke(xtd::array<xtd::action<>> {xtd::action<> {std::forward<args_t>(args)}...});}
 
        static auto invoke_async(xtd::array<xtd::action<>>&& actions) -> xtd::array<xtd::threading::tasks::task<>> {
          xtd::collections::generic::list<xtd::threading::tasks::task<>> tasks;
          for (const auto& action : actions)
            tasks.add(xtd::threading::tasks::task<>::factory().start_new(action));
          return tasks.to_array();
        }
        
        template<typename collection_t>
        static auto invoke_async(collection_t&& actions) -> xtd::array<xtd::threading::tasks::task<>> {
          xtd::collections::generic::list<xtd::threading::tasks::task<>> tasks;
          for (const auto& action : actions)
            tasks.add(xtd::threading::tasks::task<>::factory().start_new(action));
          return tasks.to_array();
        }
        
        template<typename ...args_t>
        static auto invoke_async(args_t&&... args) -> xtd::array<xtd::threading::tasks::task<>> {return invoke_async(xtd::array<xtd::action<>> {xtd::action<> {std::forward<args_t>(args)}...});}
      };
    }
  }
}