DetachPool.h

Go to the documentation of this file.

/***************************************
        Auteur : Pierre Aubert
        Mail : pierre.aubert@lapp.in2p3.fr
        Licence : CeCILL-C
****************************************/
 
#ifndef __DETACHPOOL_H__
#define __DETACHPOOL_H__
 
#include <unistd.h>
#include <thread>
#include <list>
#include <mutex>
#include <string>
#include <iostream>
 
#include "phoenix_thread_clock.h"
 
#define PEXIT_STATUS_NOT_FIHISHED 0
#define PEXIT_STATUS_OK 1
#define PEXIT_STATUS_FAIL 2

struct ThreadDetachInfo{
        std::string description;
        int exitStatus;
};
 
typedef std::list<ThreadDetachInfo> ListThreadDetachInfo;

class DetachPool{
        public:
                DetachPool();
                DetachPool(const DetachPool & other);
                virtual ~DetachPool();
                DetachPool & operator = (const DetachPool & other);
                
                void setRefreshTime(PEllapsedTime refreshTime);
                PEllapsedTime getRefreshTime() const;
                
                void setDestructionWaitTime(PEllapsedTime destructorWaitTime);
                PEllapsedTime getDestructorWaitTime() const;
                
                ListThreadDetachInfo getListThreadInfo();
                
                template<typename _Callable, typename... _Args>
                void addThread(const std::string & description, _Callable&& __f, _Args&&... __args);
                void removeFinishedThread(std::ostream & out = std::cout);
                
                void refresh();
                void waitUntilAllFinish(PEllapsedTime maxWaitTime = 10000000);   //Wait 10 seconds by default
                
        protected:
                void copyDetachPool(const DetachPool & other);
                
        private:
                void initialisationDetachPool();
                
                std::mutex p_mtx;
                PEllapsedTime p_refreshTime;
                PhoenixTime p_timeLastRefresh;
                ListThreadDetachInfo p_listThreadInfo;
                PEllapsedTime p_destructorWaitTime;
};
 
std::string phoenix_statusToString(int exitStatus);
void phoenix_printThreadStatus(const ListThreadDetachInfo & listThreadInfo, std::ostream & out = std::cout);
 
#include "DetachPool_impl.h"
 
#endif