ThreadManager.hpp

Go to the documentation of this file.

// ANNA - Anna is Not Nothingness Anymore                                                         //
//                                                                                                //
// (c) Copyright 2005-2015 Eduardo Ramos Testillano & Francisco Ruiz Rayo                         //
//                                                                                                //
// See project site at http://redmine.teslayout.com/projects/anna-suite                           //
// See accompanying file LICENSE or copy at http://www.teslayout.com/projects/public/anna.LICENSE //


#ifndef anna_core_mt_ThreadManager_hpp
#define anna_core_mt_ThreadManager_hpp

#include <string>

#include <anna/core/mt/SafeRecycler.hpp>
#include <anna/core/mt/Thread.hpp>

#include <anna/core/core.hpp>

namespace anna {

class Semaphore;

class ThreadManager : SafeRecycler <Thread> {
public:
  struct Mode {
    enum _v {
      None,
      Unlimit, 
      ExceptionWhenFull, 
      LockWhenFull 
    };

    anna_declare_enum(Mode);
  };

  typedef iterator thread_iterator;

  ThreadManager(const char* name, const Mode::_v mode, const int maxSize, const int flags = Thread::Flag::None);

  ThreadManager(const char* name, const int flags = Thread::Flag::None);

  virtual ~ThreadManager();

  const std::string& getName() const { return a_name; }

  Thread* createThread() noexcept(false);

  void join() noexcept(false);

  thread_iterator thread_begin() { return begin(); }

  thread_iterator thread_end() { return end(); }

  static Thread* thread(thread_iterator ii) { return SafeRecycler <Thread>::data(ii); }

  std::string asString() const ;

private:
  const std::string a_name;
  const Mode::_v a_mode;
  const int a_maxSize;
  Semaphore* a_semaphore;
  const int a_threadFlags;
  bool a_destroying;

  // Se invoca cuando el thread detecta que va a terminar y que tiene una factoria asociada.
  void releaseThread(Thread* thread) noexcept(false);

  friend class Thread;
};

} //namespace anna

#endif