thread.h.bak

网络socket,IO,线程池

#ifndef _M_THREAD_2004_7_28_ZHY_H
#define _M_THREAD_2004_7_28_ZHY_H

namespace thread{

class ThreadBase
{
public:
	////////////////////////////////////////////////////////////////////////////
	// Constructors / Destructor                                              //
	////////////////////////////////////////////////////////////////////////////
	
	// Constructor
	ThreadBase(void);
	
	// Desturctor
	virtual ~ThreadBase();
	
	// Priority is the same with MFC
	enum	THREAD_PRIORITY
	{
		PRIORITY_HIGHEST		=	7,
		PRIORITY_ABOVE_NORMAL	=	1,
		PRIORITY_NORMAL			=	0,
		PRIORITY_BELOW_NORMAL	=	-1,
		PRIORITY_LOWEST			=	-7,
	};
	
protected:
	////////////////////////////////////////////////////////////////////////////
	// Implemetation		                                          //
	////////////////////////////////////////////////////////////////////////////
	
	typedef unsigned 	(__stdcall * ThreadFunc)(void * arg);
	static int 		Start(ThreadFunc func,void * arg,int nStackSize,int nPrio);		
	
    	void	*		m_thread;	
    	unsigned int		m_threadID;	
};

class Thread : public ThreadBase
{
public:
	////////////////////////////////////////////////////////////////////////////
	// Constructors / Destructor                                              //
	////////////////////////////////////////////////////////////////////////////
	
	// Constructor
	Thread();
	
	// Destructor
	virtual ~Thread(void); 
	
	////////////////////////////////////////////////////////////////////////////
	// Inline Set/Get Operations                                              //
	////////////////////////////////////////////////////////////////////////////
	inline	unsigned int		GetThreadID() const { return m_threadID; }
	inlie	int			GetThreadResult() const { return m_nThreadResult; }
	
	void			StartEx(int nStackSize = 64 * 1024,int nPriority = ThreadBase::PRIORITY_NORMAL) throw(MException);
	// Stop the thread
	void			Stop();
	int			StopEx();	
protected:
	virtual int		Run() = 0;	
	
	virtual void 		OnDelete(){}
	virtual void 		OnException(CException& e) {}
	
	int			WaitUntilStop();	
private:
	static unsigned __stdcall	ThreadProxy(void * arg);
		
	int			m_nThreadResult;
		
	bool			m_bWantExit;
	CEvent			m_evHasExit;
};


}
#endif