AlgThread.h

Go to the documentation of this file.

#ifndef ANP_ALGTHREAD_H
#define ANP_ALGTHREAD_H

// $Id: AlgThread.h,v 1.2 2008/03/10 19:58:06 rustem Exp $
//
// Simple wrapper algorithm which is capable of running
// AlgSnarl::Run() function in separate thread.
//  There are two thread managing tools
//     1) fMutex which is locked whenever AlgThread data member can modified
//     2) fThread is pthread_t id of current thread
//

// C/C++
#include <algorithm>
#include <map>

#ifndef __CINT__
#include <pthread.h>
#else
struct pthread_t;
#endif

// Local
#include "PhysicsNtuple/AlgSnarl.h"
#include "PhysicsNtuple/Mutex.h"

namespace Anp
{
   void* run_alg_thread(void *data_);

   class AlgThread
   {
   public:
      
      AlgThread(Handle<AlgSnarl> alg, const std::string &name);
      ~AlgThread();
      
      bool Init(const Header &header);

      void Run(Record &record, bool new_thread);

      int Join(void);

      void End(const DataBlock &block);

      const Record& GetRecord() const;

      unsigned int NPass() const;
      unsigned int NFail() const;

   private:

      void Run();

      friend void* run_alg_thread(void *);

   private:

      //
      // Default ctor, copy ctor and assignment are not allowed.
      //
      AlgThread();
      AlgThread(const AlgThread &);
      AlgThread& operator=(const AlgThread &);

   private:

      Mutex     fMutex;
      pthread_t fThread;
      int       fThreadStatus;

      Handle<AlgSnarl> fAlg;
      std::string      fName;
      
      Record fRecord;

      unsigned int fNPass;
      unsigned int fNFail;
   };

   //
   // Utility function that helps with removal of data keys
   //
   struct PrevDataKey : public std::unary_function<double, void>
   {
      PrevDataKey();
      PrevDataKey(DataIter ibeg, DataIter iend);
      explicit PrevDataKey(const std::vector<short> &kvec_);

      bool operator()(const Data &data) const;
      bool operator()(Event &event) const;
      bool operator()(Track &track) const;
      
      private:
      
      DataVec dvec;
      bool valid;
   };

   //
   // Inlined member functions
   //
   inline const Record& AlgThread::GetRecord() const { return fRecord; }
   inline unsigned int AlgThread::NPass() const { return fNPass; }
   inline unsigned int AlgThread::NFail() const { return fNFail; }
}

#endif

---