workthread.h

短信群发系统

// WorkThread.h: interface for the WorkThread class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_WORKTHREAD_H__02D4BF66_97C9_4254_AA6A_24D36BB28682__INCLUDED_)
#define AFX_WORKTHREAD_H__02D4BF66_97C9_4254_AA6A_24D36BB28682__INCLUDED_

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

#include "sms.h"
#include "SmsManager.h"
#include "MainFrm.h"
class CMainFrame;


//工作线程类
class WorkThread  
{
public:
	void init(CWnd* pWnd);
	void SaveSendMsg(SM_PARAM * param, int &SendState);
	WorkThread(CMainFrame * pMainFrm);
	virtual ~WorkThread();	
	CMainFrame* m_pMainFrame;

	int			m_orderId;					//订单ID
	int			m_SendState;
	int			m_sendIn;					// 
	int			m_sendOut;					// 
	int			m_recvIn;					//
	int			m_recvOut;					//
	
	CRITICAL_SECTION m_csSend;				// 与发送相关的临界段
	CRITICAL_SECTION m_csRecv;				// 与接收相关的临界段

	HANDLE m_hKillThreadEvent;				// 通知子线程关闭的事件
	HANDLE m_hThreadKilledEvent;			// 子线程宣告关闭的事件

	int			m_recvMsgCount;				// 接收数量
	SM_PARAM	m_SendQueue[100];			// 发送队列
	SM_PARAM	m_RecvQueue[100];			// 接收队列
	void PutToSendQueue(SM_PARAM* pParam);		// 把消息放入发送队列
	BOOL GetFromSendQueue(SM_PARAM* pParam);	// 从发送队列读取消息
	void PutToRecvQueue(SM_PARAM* pParam, int count);	// 把读取来的消息放入接收队列
	BOOL GetFromRecvQueue(SM_PARAM* pParam);			// 重接收队列中读取一条短消息
	void GetOrderId(int &order_id);
	static UINT wordThread(LPVOID pParam);	// 收发线程
};

#endif