ONCRPCThreadCollection.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2017 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef JIVEXML_ONCRPCTHREADCOLLECTION_H
#define JIVEXML_ONCRPCTHREADCOLLECTION_H
 
#include <vector>
#include <pthread.h>
#include <semaphore.h>
 
namespace JiveXML{
  
  class ThreadCollection : private std::vector<pthread_t> {
 
    public:
      
      //Constructor
      ThreadCollection();
 
      //Destructor
      ~ThreadCollection();
 
      //Add a thread
      void AddThread( const pthread_t& thread );
 
      //Wait till the thread has been added
      void WaitAdd();
 
      //Remove a thread
      void RemoveThread( const pthread_t& thread );
 
      //Wait for all threads to finish
      void JoinAll();
 
      //Return number of threads
      //Can't be const as it requires mutex
      int NumberOfThreads();
      
    private:
      //mutex to assure no conflicts when adding/removing threads
      pthread_mutex_t m_mutex;
      //Semaphore to assure we add all threads
      sem_t  m_semaphore;
  };
 
}
#endif