---

CThreadManagersPool.hpp

Go to the documentation of this file.

#ifndef CThreadManagersPool_h
#define CThreadManagersPool_h 1

#include <map>
#include <string>
#include <ace/Thread_Manager.h>
#include <ace/Singleton.h>

#include <ace/Synch.h>

// CThreadException
#include "jic/exc/CThreadException.hpp"

namespace THREAD {

  typedef std::map<std::string,ACE_Thread_Manager *> ThreadManagersMap;

  //    Pool de Thead Managers.  Actualmente tiene dependencia
  //    directa con los threads manager de ACE. Se podría
  //    desacoplar, pero de momento no se ha hecho.

  class CThreadManagersPool 
  {

    public:
        CThreadManagersPool();

        ~CThreadManagersPool();

        //      Obtiene un thread manager determinado. Una vez creado un
        //      Thread Manager ya no se destruye.
        //      El Thread Manager cuando se crea, se hace con todas sus
        //      propiedades por defecto.
        ACE_Thread_Manager & getThreadManager (const std::string &strIdThreadManager);

        //      Cancela todos los threads de todos los Threads Managers
        void cancelAll (bool bAsyncCancel = false);

        //      Cancela todos los threads de un determinado Thread Manger
        void cancel (const std::string &strIdThreadManager, bool bAsyncCancel = false) throw (CThreadException);

        //      Suspende todos los threads de todos los Thead Manager
        void suspendAll ();

        //      Activa todos los threads de todos los Thead Manager
        void resumeAll ();

        //      Suspende todos los threads de un determinaod Thead
        //      Manager
        void suspend (const std::string &strIdThreadManager) throw (CThreadException);

        //      Activa todos los threads de un determinaod Thead Manager
        void resume (const std::string &strIdThreadManager) throw (CThreadException);

      // Additional Public Declarations

    protected:
      // Additional Protected Declarations

    private:

        void cancelByRef (const ThreadManagersMap::iterator &itThreadManagersMap, bool bAsyncCancel);

        void suspendByRef (const ThreadManagersMap::iterator &itThreadManagersMap);

        void resumeByRef (const ThreadManagersMap::iterator &itThreadManagersMap);

        void find (ThreadManagersMap::iterator &itThreadManagersMap, const std::string &strIdThreadManager, const std::string &strErrMsg) throw (CThreadException);

      // Additional Private Declarations
        ACE_Thread_Mutex m_mutex;
    private: 
      // Data Members for Class Attributes

        ThreadManagersMap m_pool;

      // Additional Implementation Declarations

  };

  typedef ACE_Unmanaged_Singleton<CThreadManagersPool,ACE_SYNCH_MUTEX> ThreadManagersPool;

  // Class THREAD::CThreadManagersPool 

} // namespace THREAD

#endif

---