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(const xtd::array<xtd::action<>>& actions) -> void {
          xtd::collections::generic::list<xtd::threading::tasks::task<>> tasks;
          for (const auto& action : actions)
            tasks.add(xtd::threading::tasks::task<>::factory().start_new(action));
          task<>::wait_all(tasks);
        }
        
        template<class collection_t>
        static auto invoke(const collection_t& actions) -> void {
          xtd::collections::generic::list<xtd::threading::tasks::task<>> tasks;
          for (const auto& action : actions)
            tasks.add(xtd::threading::tasks::task<>::factory().start_new(action));
          task<>::wait_all(tasks);
        }
 
        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(const xtd::array<std::function<void()>>& actions) -> void {
          xtd::collections::generic::list<xtd::threading::tasks::task<>> tasks;
          for (const auto& action : actions)
            tasks.add(xtd::threading::tasks::task<>::factory().start_new(action));
          task<>::wait_all(tasks);
        }
      };
    }
  }
}