Subversion Repositories HomeAutomation

Rev

Rev 1124 | 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. #include <iostream>
  27.  
  28. template <class T>
  29. class Thread
  30. {
  31. public:
  32.     Thread()
  33.     {
  34.         myIsCreated = false;
  35.         myError = 0;
  36.     };
  37.     virtual ~Thread()
  38.     {
  39.         stop();
  40.     };
  41.  
  42.     bool stop()
  43.     {
  44.  
  45.         if (!myIsCreated)
  46.         {
  47.             //cout << "Thread is not running, can not be stopped " << endl;
  48.             return true;
  49.         }
  50.  
  51.         //cout << "Thread cancel to run " << endl;
  52.  
  53.         myError = pthread_cancel(myHandle);
  54.         //myError = pthread_detach(myHandle);
  55.         //cout << "Thread cancel returned " << myError << endl;
  56.  
  57.  
  58.  
  59.         //if (joinThread)
  60.         {
  61.             join();
  62.         }
  63.  
  64.         myIsCreated = false;
  65.  
  66.         return myError == 0;
  67.     };
  68.  
  69.     bool start()
  70.     {
  71.         myError = pthread_create(&myHandle, NULL, T::doThread, (void*)this);
  72.  
  73.         if (myError != 0)
  74.         {
  75.             myIsCreated = false;
  76.             return false;
  77.         }
  78.  
  79.         myIsCreated = true;
  80.         return true;
  81.     };
  82.  
  83.     bool join()
  84.     {
  85.         if (!myIsCreated)
  86.             return false;
  87.  
  88.         myError = pthread_join(myHandle, NULL);
  89.  
  90.         if (myError != 0)
  91.         {
  92.             myIsCreated = false;
  93.             return false;
  94.         }
  95.  
  96.         myIsCreated = true;
  97.         return true;
  98.     };
  99.  
  100.     int getError()
  101.     {
  102.         return myError;
  103.     };
  104.  
  105.     static void *doThread(void* ptr)
  106.     {
  107.         ((T*)ptr)->run();
  108.     };
  109.  
  110.     virtual void run() { };
  111.  
  112. private:
  113.     bool myIsCreated;
  114.     pthread_t myHandle;
  115.     int myError;
  116. };
  117.  
  118. #endif  /* _THREAD_H */
  119.  
  120.