ExternalServerArray.hpp

#pragma once
#include <samchon/API.hpp>

#include <samchon/templates/external/ExternalSystemArray.hpp>
#   include <samchon/templates/external/ExternalServer.hpp>

#include <thread>

namespace samchon
{
namespace templates
{
namespace external
{
    template <class System = ExternalServer>
    class ExternalServerArray
        : public virtual ExternalSystemArray<System>
    {
    public:
        ExternalServerArray()
            : ExternalSystemArray<System>()
        {
        };
        virtual ~ExternalServerArray() = default;

        virtual void connect()
        {
            std::vector<std::thread> thread_array;

            for (size_t i = 0; i < size(); i++)
            {
                auto external_server = std::dynamic_pointer_cast<ExternalServer>(this->at(i));
                if (external_server == nullptr)
                    continue;

                thread_array.emplace_back(&ExternalServer::connect, external_server.get());
            }

            for (size_t i = 0; i < thread_array.size(); i++)
                thread_array[i].join();
        };
    };
};
};
};