FMTtaskhandler.hpp

Go to the documentation of this file.

/*
Copyright (c) 2019 Gouvernement du Québec
 
SPDX-License-Identifier: LiLiQ-R-1.1
License-Filename: LICENSES/EN/LiLiQ-R11unicode.txt
*/
#ifndef FMTTASKHANDLER_H_INCLUDED
#define FMTTASKHANDLER_H_INCLUDED
#include <memory>
#include "FMTobject.hpp"
 
namespace Parallel
{
    class FMTtask;
    // DocString: FMTtaskhandler
    class FMTEXPORT FMTtaskhandler : public Core::FMTobject
    {
    // DocString: FMTtaskhandler::maxnumberofthread
    unsigned int maxnumberofthread;
    // DocString: FMTtaskhandler::alltasks
    std::vector<std::unique_ptr<FMTtask>>alltasks;
    // DocString: FMTtaskhandler::splittasks
    void splittasks();
    // DocString: FMTtaskhandler::finalize
    void finalize(std::unique_ptr<FMTtask>& lasttask);
    // DocString: FMTtaskhandler::logtasktime
    void logtasktime(const std::chrono::time_point<std::chrono::high_resolution_clock>& startime) const;
    public:
        // DocString: FMTtaskhandler::FMTtaskhandler(const std::unique_ptr<FMTtask>&,unsigned int)
        FMTtaskhandler(const std::unique_ptr<FMTtask>& maintask,
                        unsigned int maxthread = 0);
        // DocString: ~FMTtaskhandler()
        ~FMTtaskhandler()=default;
        // DocString: FMTtaskhandler::FMTtaskhandler(const Parallel::FMTtask&,unsigned int)
        FMTtaskhandler(const FMTtask& maintask,
            unsigned int maxthread = 0);
        // DocString: FMTtaskhandler::FMTtaskhandler()
        FMTtaskhandler() = default;
        // DocString: FMTtaskhandler::FMTtaskhandler(const FMTtaskhandler)
        FMTtaskhandler(const FMTtaskhandler& rhs);
        // DocString: FMTtaskhandler::operator=
        FMTtaskhandler& operator =(const FMTtaskhandler& rhs);
        // DocString: FMTtaskhandler::gettasks
        const std::vector<std::unique_ptr<FMTtask>>& gettasks() const;
        // DocString: FMTtaskhandler::gettasksfromdynamiccast
        template<class ptrtype>
        const std::vector<const ptrtype*> gettasksfromdynamiccast() const
        {
            std::vector<const ptrtype*>castedptr;
            for (const std::unique_ptr<FMTtask>& task : alltasks)
            {
                castedptr.push_back(dynamic_cast<const ptrtype*>(task.get()));
            }
            return castedptr;
        }
        // DocString: FMTtaskhandler::conccurentrun
        void conccurentrun();
        // DocString: FMTtaskhandler::ondemandrun
        void ondemandrun();
        // DocString: FMTtaskhandler::passinlogger
        void passinlogger(const std::shared_ptr<Logging::FMTlogger>& logger) override;
    };
 
}
 
#endif