src/Thread.cpp

   1 // Copyright 2008 Brian Caine
   2
   3 // This file is part of Potpourri.
   4
   5 // Potpourri is free software: you can redistribute it and/or modify
   6 // it under the terms of the GNU General Public License as published by
   7 // the Free Software Foundation, either version 3 of the License, or
   8 // (at your option) any later version.
   9
  10 // Potpourri is distributed in the hope that it will be useful,
  11 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  12 // MERCHANTIBILITY of FITNESS FOR A PARTICULAR PURPOSE. See the
  13 // GNU General Public License for more details.
  14
  15 // You should have received a copy of the GNU General Public License
  16 // along with Potpourri. If not, see <http://www.gnu.org/licenses/>.
  17
  18
  19 // NOTES:
  20
  21 // This is the sauce for the Thread class
  22
  23 #include <iostream>
  24
  25 #include "Thread.h"
  26
  27 using namespace fragrant;
  28
  29 Thread* Thread::makeThread(ThreadFunc function,
  30                            std::vector<fragrant::Variant*> params)
  31 {
  32   Thread* thread = new Thread(function, params);
  33
  34   if (!was_made)
  35     {
  36       delete thread;
  37       thread = 0;
  38       std::cerr << "Thread::makeThread(): Error making thread" << std::endl;
  39     }
  40   else
  41     thread->run();
  42
  43   return thread;
  44 }
  45
  46 Thread::~Thread()
  47 {
  48   if (!errnum)
  49     {
  50       pthread_join(threadnum, 0);
  51     }
  52 }
  53
  54 Thread::Thread(ThreadFunc function, std::vector<fragrant::Variant*> params)
  55 {
  56   // no reason to refuse
  57   was_made = static_cast<bool>(function);
  58
  59   func = function;
  60   func_params = params;
  61
  62   threadnum = 0;
  63   errnum = 0;
  64 }
  65
  66 void Thread::run()
  67 {
  68   errnum = pthread_create(&threadnum, 0, Thread::run,
  69                              static_cast<void*>(this));
  70   if (errnum)
  71     {
  72       threadnum = 0;
  73       std::cerr << "Thread::run(): Error starting thread" << std::endl;
  74     }
  75
  76   return;
  77 }
  78
  79 void* Thread::run(void* thread)
  80 {
  81   Thread* the_thread = static_cast<Thread*>(thread);
  82
  83   ThreadFunc func = the_thread->func;
  84   std::vector<fragrant::Variant*> params = the_thread->func_params;
  85
  86   func(params);
  87
  88   pthread_exit(0);
  89 }
  90
  91 bool Thread::was_made = false;