src/AsyncFramework/Thread.cpp

   1 /***************************************************************************
   2  *   Copyright (C) 2009 by Stefan Fuhrmann                                 *
   3  *   stefanfuhrmann@alice-dsl.de                                           *
   4  *                                                                         *
   5  *   This program 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 2 of the License, or     *
   8  *   (at your option) any later version.                                   *
   9  *                                                                         *
  10  *   This program is distributed in the hope that it will be useful,       *
  11  *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
  12  *   MERCHANTABILITY or 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 this program; if not, write to the                         *
  17  *   Free Software Foundation, Inc.,                                       *
  18  *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
  19  ***************************************************************************/
  20
  21 #include "stdafx.h"
  22 #include "Thread.h"
  23
  24 namespace async
  25 {
  26
  27 /// the actual thread function
  28
  29 void CThread::ThreadFunc (void* arg)
  30 {
  31 //    CCrashReportThread crashthread;
  32     CThread* self = reinterpret_cast<CThread*>(arg);
  33
  34     // maybe, we were started in "suspended" mode
  35
  36     if (self->suspended)
  37         self->resume.WaitFor();
  38
  39     // main loop
  40
  41     while (!self->terminated)
  42     {
  43         if ((*self->func)(self->args))
  44         {
  45             // auto-deletion
  46
  47             self->terminated = true;
  48             self->done.Set();
  49             delete self;
  50
  51             return;
  52         }
  53
  54         if (self->suspended)
  55             self->resume.WaitFor();
  56     }
  57
  58     // indicate that the thread is no longer processing any data
  59
  60     self->done.Set();
  61 }
  62
  63 /// auto-start thread during construction
  64
  65 CThread::CThread (bool (*func)(void *), void* args, bool startSuspended)
  66     : thread (NULL)
  67     , terminated (false)
  68     , suspended (startSuspended)
  69     , func (func)
  70     , args (args)
  71 {
  72     thread = _beginthread (&ThreadFunc, 0, this);
  73 }
  74
  75 CThread::~CThread(void)
  76 {
  77     if (thread != 0)
  78         Terminate();
  79 }
  80
  81 /// thread control
  82
  83 void CThread::Suspend()
  84 {
  85     resume.Reset();
  86     suspended = true;
  87 }
  88
  89 void CThread::Resume()
  90 {
  91     suspended = false;
  92     resume.Set();
  93 }
  94
  95 void CThread::Terminate()
  96 {
  97     terminated = true;
  98
  99     Resume();
 100     done.WaitFor();
 101 }
 102
 103 }