apps/utils/net/roshttpd/common/thread.cpp

   1 /*
   2  * COPYRIGHT:   See COPYING in the top level directory
   3  * PROJECT:     ReactOS HTTP Daemon
   4  * FILE:        thread.cpp
   5  * PURPOSE:     Generic thread class
   6  * PROGRAMMERS: Casper S. Hornstrup (chorns@users.sourceforge.net)
   7  * REVISIONS:
   8  *   CSH  01/09/2000 Created
   9  */
  10 #include <debug.h>
  11 #include <assert.h>
  12 #include <windows.h>
  13 #include <thread.h>
  14
  15 // This is the thread entry code
  16 DWORD WINAPI ThreadEntry(LPVOID parameter)
  17 {
  18         ThreadData *p = (ThreadData*) parameter;
  19
  20     p->ClassPtr->Execute();
  21
  22         SetEvent(p->hFinished);
  23         return 0;
  24 }
  25
  26 // Default constructor
  27 CThread::CThread()
  28 {
  29         bTerminated = FALSE;
  30         // Points to the class that is executed within thread
  31         Data.ClassPtr = this;
  32         // Create synchronization event
  33         Data.hFinished = CreateEvent(NULL, TRUE, FALSE, NULL);
  34
  35         // FIXME: Do some error handling
  36         assert(Data.hFinished != NULL);
  37
  38         // Create thread
  39     hThread = CreateThread(NULL, 0, ThreadEntry, &Data, 0, &dwThreadId);
  40
  41         // FIXME: Do some error handling
  42         assert(hThread != NULL);
  43 }
  44
  45 // Default destructor
  46 CThread::~CThread()
  47 {
  48         if ((hThread != NULL) && (Data.hFinished != NULL)) {
  49                 if (!bTerminated)
  50                         Terminate();
  51                 WaitForSingleObject(Data.hFinished, INFINITE);
  52                 CloseHandle(Data.hFinished);
  53                 CloseHandle(hThread);
  54                 hThread = NULL;
  55         }
  56 }
  57
  58 // Execute thread code
  59 void CThread::Execute()
  60 {
  61         while (!bTerminated) Sleep(0);
  62 }
  63
  64 // Post a message to the thread's message queue
  65 BOOL CThread::PostMessage(UINT Msg, WPARAM wParam, LPARAM lParam)
  66 {
  67         return PostThreadMessage(dwThreadId, Msg, wParam, lParam);
  68 }
  69
  70 // Gracefully terminate thread
  71 void CThread::Terminate()
  72 {
  73         bTerminated = TRUE;
  74 }
  75
  76 // Returns TRUE if thread is terminated, FALSE if not
  77 BOOL CThread::Terminated()
  78 {
  79         return bTerminated;
  80 }