retrievalthread.h

远程网络监视程序的源码

//---------------------------------------------------------------------------
//
// RetrievalThread.h
//
// SUBSYSTEM: 
//              Monitoring process creation and termination  
//				
// MODULE:    
//              Provides an interface for handling queued items
//
// DESCRIPTION:
//
// AUTHOR:		Ivo Ivanov
//                                                                         
//---------------------------------------------------------------------------

#if !defined(_RETRIEVALTHREAD_H_)
#define _RETRIEVALTHREAD_H_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000

//---------------------------------------------------------------------------
//
// Includes
//
//---------------------------------------------------------------------------
#include "CustomThread.h"

//---------------------------------------------------------------------------
//
// Forward declarations
//
//---------------------------------------------------------------------------

class CQueueContainer;

//---------------------------------------------------------------------------
//
// class CQueueReadThread
//
//---------------------------------------------------------------------------

class CQueueReadThread: public CCustomThread  
{
public:
	CQueueReadThread(
		TCHAR*           pszThreadGuid,
		CQueueContainer* pQueue
		);
	virtual ~CQueueReadThread();
private:
	//
	// A pointer to the queue object
	//
	CQueueContainer* m_pQueueManager;
	//
	// Event which is signaled when there is available element
	// in the queue to be retrieved
	//
	HANDLE m_hEventAvailable;
	//

protected:
	//
	// A user supplied implementation of the thread function.
	// Override Run() and insert the code that should be executed when 
	// the thread runs.
	//
	virtual void Run();

public:

	// A method for accessing handle to an internal event handle
	HANDLE Get_EventAvailable() const;
	void EventNotify(bool bSetEvent);
};

#endif // !defined(_RETRIEVALTHREAD_H_)
//----------------------------End of the file -------------------------------