Subversion Repositories HomeAutomation

Rev

Rev 983 | Rev 1026 | Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | SVN | RSS feed

  1. /***************************************************************************
  2.  *   Copyright (C) November 29, 2008 by Mattias Runge                             *
  3.  *   mattias@runge.se                                                      *
  4.  *   thread.h                                            *
  5.  *                                                                         *
  6.  *   This program is free software; you can redistribute it and/or modify  *
  7.  *   it under the terms of the GNU General Public License as published by  *
  8.  *   the Free Software Foundation; either version 2 of the License, or     *
  9.  *   (at your option) any later version.                                   *
  10.  *                                                                         *
  11.  *   This program is distributed in the hope that it will be useful,       *
  12.  *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
  13.  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
  14.  *   GNU General Public License for more details.                          *
  15.  *                                                                         *
  16.  *   You should have received a copy of the GNU General Public License     *
  17.  *   along with this program; if not, write to the                         *
  18.  *   Free Software Foundation, Inc.,                                       *
  19.  *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
  20.  ***************************************************************************/
  21.  
  22. #ifndef _THREAD_H
  23. #define _THREAD_H
  24.  
  25. #include <pthread.h>
  26.  
  27. template <class T>
  28. class Thread
  29. {
  30. public:
  31.     Thread()
  32.     {
  33.         myIsCreated = false;
  34.         myError = 0;
  35.     };
  36.     ~Thread()
  37.     {
  38.         stop();
  39.     };
  40.  
  41.     bool stop()
  42.     {
  43.         if (!myIsCreated)
  44.             return true;
  45.  
  46.         myError = pthread_cancel(myHandle);
  47.         join();
  48.         myIsCreated = false;
  49.  
  50.         return myError == 0;
  51.     };
  52.    
  53.     bool start()
  54.     {
  55.         myError = pthread_create(&myHandle, NULL, T::doThread, (void*)this);
  56.        
  57.         if (myError != 0)
  58.         {
  59.             myIsCreated = false;
  60.             return false;
  61.         }
  62.  
  63.         myIsCreated = true;
  64.         return true;
  65.     };
  66.  
  67.     bool join()
  68.     {
  69.         if (!myIsCreated)
  70.             return false;
  71.  
  72.         myError = pthread_join(myHandle, NULL);
  73.  
  74.         if (myError != 0)
  75.         {
  76.             myIsCreated = false;
  77.             return false;
  78.         }
  79.  
  80.         myIsCreated = true;
  81.         return true;
  82.     };
  83.  
  84.     int getError()
  85.     {
  86.         return myError;
  87.     };
  88.  
  89.     static void *doThread(void* ptr)
  90.     {
  91.         ((T*)ptr)->run();
  92.     };
  93.  
  94.     virtual void run() { };
  95.  
  96. private:
  97.     bool myIsCreated;
  98.     pthread_t myHandle;
  99.     int myError;
  100. };
  101.  
  102. #endif  /* _THREAD_H */
  103.  
  104.