PMultiThreadProgress.h

Go to the documentation of this file.

/***************************************
        Auteur : Pierre Aubert
        Mail : pierre.aubert@lapp.in2p3.fr
        Licence : CeCILL-C
****************************************/
 
#ifndef __PMULTITHREADPROGRESS_H__
#define __PMULTITHREADPROGRESS_H__
 
#include <string>
#include <vector>
#include <map>
#include <thread>
 
#include <mutex>
#include "PString.h"

struct ProgressElement{
        int progress;
        int prevProgress;
        int progressMax;
        PString name;
        bool isEndError;
};

typedef std::vector<ProgressElement> VecProgressElement;

class PMultiThreadProgress{
        public:
                PMultiThreadProgress(size_t nbExpectedProgressBar = 1lu);
                PMultiThreadProgress(const PMultiThreadProgress & other);
                virtual ~PMultiThreadProgress();
                PMultiThreadProgress & operator = (const PMultiThreadProgress & other);
                
                void setNbExpectedProgressBar(size_t nbExpectedProgressBar);
                
                size_t addProgressBar(const PString & name, int progressMax = 1);
                void incrementProgress(size_t index);
                void setError(size_t index);
                
                bool isFinished() const;
                void print();
                void printSummary() const;
                
        protected:
                void copyPMultiThreadProgress(const PMultiThreadProgress & other);
                
        private:
                void initialisationPMultiThreadProgress(size_t nbExpectedProgressBar);
                bool isModified();
                void eraseProgressBar(size_t nbColTerminal);
                void printProgressBar(size_t nbColTerminal);
                void printAllFinshedProgressBar();
                size_t getNbColTerminal() const;
                
                size_t p_alreadyPrintedLine;
                VecProgressElement p_vecProgressElement;
                std::mutex p_currentMutex;
                size_t p_previousNbProgressBar;
                size_t p_nbExpectedProgressBar;
};
 
void phoenix_print_parallel_progress(PMultiThreadProgress & progress, int refreshSecond);
 
#endif