---

wefts_thread.h

Go to the documentation of this file.

/*
   wefts_thread.h
   Main thread class

   $Id: wefts_thread.h,v 1.2 2003/08/05 15:40:20 jonnymind Exp $
---------------------------------------------
   Begin      : 2003-08-02 23:45
   Author     : Giancarlo Niccolai

   Last modified because:

*/

/**************************************************************************
*   This program is free software; you can redistribute it and/or modify  *
*   it under the terms of the GNU Library General Public License as       *
*   published by the Free Software Foundation; either version 2.1 of the  *
*   License, or (at your option) any later version.                       *
***************************************************************************/

#ifndef WT_THREAD_H
#define WT_THREAD_H

#ifdef __extern_c
extern "C" {
#endif

#include <pthread.h>

#ifdef __extern_c
}
#endif

#include <wefts_counter.h>



namespace Wefts {

extern Counter runningThreads;

extern Counter startedThreads;

class Thread
{
private:
   inline virtual void executionEnd() { m_thid = 0; }

   void setCancel() { setCancel( m_canCancel ); }

protected:
   void *m_runReturnValue;
   pthread_t   m_thid;
   bool        m_canCancel;
   void        *m_thread_data;
   bool        m_detached;
   bool        m_stopped;

   int         m_thSequence;

   void testCancel() { pthread_testcancel(); if ( m_stopped ) pthread_exit(0); }

   void setCancel( bool cando );


public:
   Thread();

   virtual ~Thread();

   bool start( bool detachable = false, bool cancelable = true );

   bool stop();

   void detach() { m_detached = true; }
   bool detached() { return m_detached; }

   virtual void *join();

   bool running() { return m_thid == 0; }

   pthread_t getId() { return m_thid; }

   inline void setData( void *data ) { m_thread_data = data; }

   inline int  sequence() { return m_thSequence; }

   virtual void cleanup() {};

   virtual void *run()=0;

   friend void *s_ThreadRunFunc( void *);
   friend void s_ThreadCleanupper( void *);

};

}

#endif
/* end of wefts_thread.h */

---