PThread Class Reference

Public Member Functions
template<class WORKER >
	PThread (WORKER *worker, bool destroyed=true, bool detached=true, const std::string &thread_name="")
pthread_t	id ()
pthread_t	get_id ()
bool	kill (int signo)
bool	is_alive ()
bool	detach ()
bool	join ()
bool	cancel ()

Static Public Member Functions
static void	exit ()

Static Private Member Functions
template<class WORKER >
static void	destroy (void *arg)
template<class WORKER >
static void *	create_destroy (void *arg)
template<class WORKER >
static void *	create (void *arg)

Private Attributes
pthread_t	m_th

Detailed Description

Definition at line 23 of file PThread.h.

Constructor & Destructor Documentation

PThread() [1/2]

PThread ( )

inline

Definition at line 66 of file PThread.h.

: m_th(0) {}

PThread() [2/2]

PThread ( WORKER *  worker, bool  destroyed = true, bool  detached = true, const std::string &  thread_name = ""  )

inline

Definition at line 68 of file PThread.h.

    {
      m_th = 0;
      if (destroyed) {
        if (pthread_create(&m_th, NULL, PThread::create_destroy<WORKER>,
                           (void*)worker) != 0) {
          m_th = 0;
        }
      } else {
        if (pthread_create(&m_th, NULL, PThread::create<WORKER>,
                           (void*)worker) != 0) {
          m_th = 0;
        }
      }
#if (defined(__GLIBC__) && defined(__GNU_SOURCE) && __GLIBC__ >= 2 && __GLIBC_MINOR__ >= 12)
      if ((m_th != 0) && (thread_name != "")) {
        try {
          if (pthread_setname_np(m_th, thread_name.c_str()) != 0) {
            LogFile::info("Failed to set process name %d", m_th);
          }
          char comp_name[64];
          pthread_getname_np(m_th, comp_name, 16);
          if (strcmp(thread_name.c_str(), comp_name) != 0) {
            prctl(PR_SET_NAME, thread_name.c_str());
          }
        } catch (const std::exception& e) {
          LogFile::error(e.what());
        }
      }
#endif
      if (detached) {
        detach();
        m_th = 0;
      }
    }

~PThread()

~PThread ( )

inline

Definition at line 103 of file PThread.h.

{}

Member Function Documentation

cancel()

bool cancel ( )

inline

Definition at line 124 of file PThread.h.

    {
      if (m_th == 0) return false;
      return ::pthread_cancel(m_th) == 0;
    }

create()

static void * create ( void *  arg )

inlinestaticprivate

Definition at line 49 of file PThread.h.

    {
      WORKER* worker = (WORKER*)arg;
      pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
      pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
      try {
        worker->run();
      } catch (const std::exception& e) {
        LogFile::fatal(e.what());
      }
      return NULL;
    }

create_destroy()

static void * create_destroy ( void *  arg )

inlinestaticprivate

Definition at line 34 of file PThread.h.

    {
      WORKER* worker = (WORKER*)arg;
      pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
      pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
      pthread_cleanup_push(PThread::destroy<WORKER>, arg);
      try {
        worker->run();
      } catch (const std::exception& e) {
        LogFile::fatal(e.what());
      }
      pthread_cleanup_pop(1);
      return NULL;
    }

destroy()

static void destroy ( void *  arg )

inlinestaticprivate

Definition at line 27 of file PThread.h.

    {
      WORKER* worker = (WORKER*)arg;
      delete worker;
      worker = NULL;
    }

detach()

bool detach ( )

inline

Definition at line 114 of file PThread.h.

    {
      if (m_th == 0) return false;
      return ::pthread_detach(m_th) == 0;
    }

exit()

static void exit ( )

inlinestatic

Definition at line 63 of file PThread.h.

{ pthread_exit(NULL); }

get_id()

pthread_t get_id ( )

inline

Definition at line 107 of file PThread.h.

{ return m_th; }

id()

pthread_t id ( )

inline

Definition at line 106 of file PThread.h.

{ return m_th; }

is_alive()

bool is_alive ( )

inline

Definition at line 113 of file PThread.h.

{ return this->kill(0); }

join()

bool join ( )

inline

Definition at line 119 of file PThread.h.

    {
      if (m_th == 0) return false;
      return ::pthread_join(m_th, NULL) == 0;
    }

kill()

bool kill ( int  signo )

inline

Definition at line 108 of file PThread.h.

    {
      if (m_th == 0) return false;
      return ::pthread_kill(m_th, signo) == 0;
    }

Member Data Documentation

m_th

pthread_t m_th

private

Definition at line 131 of file PThread.h.

---

The documentation for this class was generated from the following file:

• daq/slc/system/include/PThread.h