threaddispatcher.h

pocket pc 2003系统下的数据通讯和文件传输

#pragma once
#ifndef __CWizThreadDispatcher_H
#define __CWizThreadDispatcher_H

/////////////////////////////////////////////////////////////////////////////
// Class Interface for CWizThreadDispatcher.
// The derived class must implement:
// 1. WaitForData.
//	  The function received handle to event which becomes signaled
//    when the server shuts down.
//    The function must return FALSE if received shut down signal,
//    or wait until some data becomes availible (or whatever) and
//    return TRUE;
// 2. TreatData
//	  The function received handle to event which becomes signaled
//    when the server shuts down, and the handle to event when it
//    started to treat data (or whatever), i.e. when it's safe to
//    call WaitForData again.
// 
// IMPORTANT!!! You MUST Set hDataTakenEvent somewhere in the
// function, or deadlock will occur!!! DUMNED!!!
//
// The function must return FALSE if received shut down signal,
// or wait until data treatmen finished (or whatever) and return TRUE;

class CWizMultiThreadedWorker
{
	public:
		CWizMultiThreadedWorker() {}
		virtual ~CWizMultiThreadedWorker() {}

		virtual void Prepare     () = 0;
		virtual BOOL WaitForData (int&, HANDLE hShutDownEvent) = 0;
		virtual BOOL TreatData   (int, HANDLE hShutDownEvent, HANDLE hDataTakenEvent) = 0;
		virtual void CleanUp     () =  0;
		virtual void ShutDown	(int)=0;
		virtual void Close	(int)=0;
		
		int MaxClient;

	class Stack
	{
		public:
			Stack(CWizMultiThreadedWorker& rW)
				: m_rW(rW)
				{ m_rW.Prepare(); }
			~Stack()
				{ m_rW.CleanUp(); }
		private:
			CWizMultiThreadedWorker& m_rW;
	};
};

/////////////////////////////////////////////////////////////////////////////
// class CWizThreadDispatcher
class CWizThreadDispatcher
{
public:
	CWizThreadDispatcher (CWizMultiThreadedWorker &rWorker/*, int MaxThreads = 5*/);
	virtual ~CWizThreadDispatcher ();

public:
// Operations:
	void	Start();	// Starts Dispatching
	void	Stop();		// Signals to stop and (?) waits for all threads to exit
	void	MsgStop (HANDLE);

public:
// Classes 
	// Exceptions the class can throw: (+CMemoryException)
	struct Xeption 
	{
		Xeption(CString error)
		{
			MessageBox(NULL, error, "Error", MB_OK | MB_ICONINFORMATION );
			exit(0);
		}
	};
	struct XCannotCreate { XCannotCreate() { Xeption("Create socket error!"); } };
	struct XWaitFailed { XWaitFailed() { Xeption("Has a error when wait data"); } };

	// Event wrapper
	class Event
	{
	public:
		Event(BOOL bManualReset);
		~Event();
		void	Set();
		HANDLE	m_h;
	};
protected:
	class WorkerThread
	{
	public:
		WorkerThread(int,CWizMultiThreadedWorker &rWorker, 
				HANDLE hDataReadyEvent,
				HANDLE hStartedTreatEvent,
				HANDLE hShutDownEvent);
		friend UINT AFX_CDECL CWizThreadDispatcher_WorkerThread_Fun(LPVOID pParam);
	private:
		UINT Run();

		enum { DataWaitHCount = 2 };
		CWizMultiThreadedWorker&	m_rWorker;
		HANDLE	m_hDataWait [DataWaitHCount];
		HANDLE	m_hStartedTreatEvent;
		int index;
	};
// Implementation:
	friend UINT AFX_CDECL CWizThreadDispatcherFun(LPVOID pParam);
	friend UINT AFX_CDECL CWizThreadDispatcher_WorkerThread_Fun(LPVOID pParam);

// Virtual implementation:
	virtual UINT  Run();
// Data members
	enum { StartedTreatmentEventsCount = 2};

	int							m_nMaxThreads;
	CWizMultiThreadedWorker&	m_rWorker;
	Event						m_ShutDownEvent;
	Event*						m_HasDataEvent[MAXCLIENT];
	Event*						m_StartedDataTreatEvent[MAXCLIENT];
	HANDLE						m_ahStartedTreatmentEvents[MAXCLIENT][StartedTreatmentEventsCount];
	HANDLE*						m_ahWorkersHandles;
	HANDLE						m_hThisThread;
	HWND						m_pWnd;					
	UINT						m_nMessage;
	HANDLE closeEvent;
};

/////////////////////////////////////////////////////////////////////////////
inline CWizThreadDispatcher::Event::Event(BOOL bManualReset)
	: m_h (::CreateEvent(NULL, bManualReset, FALSE, NULL))
{
	if (m_h == NULL)
		throw CWizThreadDispatcher::XCannotCreate();
}

inline CWizThreadDispatcher::Event::~Event()
{
	if (m_h != NULL)
		VERIFY(::CloseHandle(m_h));
}

inline void CWizThreadDispatcher::Event::Set()
{
	ASSERT(m_h != NULL);
	SetEvent(m_h); // May fail because is set already
}
#endif // __CWizThreadDispatcher_H