UtilClass/ThinThread.cpp

@@ -0,0 +1,79 @@
+// ThinThread.cpp : implementation file
+// Copyright (C) 1997 by The Windward Group, All Rights Reserved
+
+#include "stdafx.h"
+#include "ThinThread.h"
+#include <process.h>    /* _beginthread, _endthread */
+
+/////////////////////////////////////////////////////////////////////////////
+// ThinThread
+CThinThread::CThinThread()
+: m_b2ndThread(FALSE)
+{
+	// Create a signaled, manual-reset event to synchronize destruction
+	m_pExitEvent = new CEvent(TRUE, TRUE);
+	ASSERT(m_pExitEvent);
+
+	// Create a non-signaled, auto-reset event to wait on for work cycle
+	m_pWorkEvent = new CEvent();
+	ASSERT(m_pWorkEvent);
+}
+
+BOOL CThinThread::CreateThread(DWORD dwCreateFlags, UINT nStackSize, 
+						   LPSECURITY_ATTRIBUTES lpSecurityAttrs, 
+						   UINT nMilliSecs)
+{
+	m_b2ndThread = TRUE;
+	m_bEndThread = FALSE;
+	m_nCycleTime = nMilliSecs;
+	m_pExitEvent->ResetEvent();	// exit event is reset until we're done
+
+	// Start second thread
+	unsigned usThreadAddr;
+	m_hThread2 = reinterpret_cast<HANDLE> (_beginthreadex(lpSecurityAttrs, nStackSize, Start, this, 1, &usThreadAddr));
+	return reinterpret_cast<unsigned long> (m_hThread2);
+}
+
+CThinThread::~CThinThread()
+{
+	delete m_pWorkEvent;
+	delete m_pExitEvent;
+}
+
+void CThinThread::KillThread2()
+{
+	// Start up the other thread so it can complete.
+	// When it does, it will set the exit event and the object can be destructed.
+	m_bEndThread = TRUE;
+	m_pWorkEvent->SetEvent();
+	CSingleLock csl(m_pExitEvent);
+	csl.Lock();					// wait for 2nd thread to finish
+	csl.Unlock();						
+}
+
+int CThinThread::Run()
+{
+	CSingleLock csl(m_pWorkEvent);		// synch on the work event
+	StartWork();						// do derived startup
+
+	while (!m_bEndThread)				// loop until we're done
+	{
+		csl.Lock(m_nCycleTime);			// wait for event or timeout
+		csl.Unlock();			
+		if (!m_bEndThread)
+			DoWork();	// then do derived work
+	}
+
+	EndWork();							// do derived shutdown
+	m_pExitEvent->SetEvent();			// set not waiting signal
+	m_b2ndThread = FALSE;
+	CloseHandle(m_hThread2);
+	_endthreadex(0);
+	return 0;
+}
+
+unsigned int __stdcall CThinThread::Start(void* pv)
+{
+	CThinThread* pMT = static_cast<CThinThread*> (pv);
+	return pMT->Run();
+}