MonitorDataTableFinisherThread.h

Go to the documentation of this file.

#ifndef CARMA_DBMS_MONITORDATATABLEFINISHERTHREAD_H
#define CARMA_DBMS_MONITORDATATABLEFINISHERTHREAD_H

#include "carma/dbms/MonitorSystemAndDBMSRelationships.h"

#include <boost/thread.hpp>
#include <string>

namespace carma {
namespace dbms {

    class DBConnection;

class MonitorDataTableFinisherThread {

public:

    explicit MonitorDataTableFinisherThread
        (const std::string& threadName, 
         const carma::dbms::DBConnection * const dbc, 
         const std::string& tableName,
         const carma::dbms::MonitorAverageType& averageType);

    ~MonitorDataTableFinisherThread( );

    bool isFinished() const;
    
    void operator()();

protected:
    
     const carma::dbms::DBConnection *dbc_;
     carma::dbms::MonitorAverageType avgType_;
     std::string tableName_;

     boost::thread thread_;
     bool finished_;
     mutable boost::mutex finishedMutex_;
};


}}

#endif // CARMA_DBMS_MONITORDATAFINISHERTHREAD_H