clientthread.h

一个多线程的网络数据采集系统（客户端）

#pragma once

#include "ClientSocket.h"

// CClientThread

class CClientThread : public CWinThread
{
	DECLARE_DYNCREATE(CClientThread)

public:
	CClientThread();           // 动态创建所使用的受保护的构造函数
	virtual ~CClientThread();
	CClientThread(CPkgQueue *pRecvQueue, CPkgQueue *pSendQueue, CWnd *pWnd, const CString& sConnStr);
protected:
	/**
	* 本线程的数据报接受队列
	**/
	CPkgQueue *m_pRecvQueue;
	/**
	* 本线程的数据报发送队列
	**/
	CPkgQueue *m_pSendQueue;
	/**
	* 与本线程通信的窗口指针
	**/
	CWnd *m_pWnd;
	/**
	* 本线程所使用的套接字指针
	**/
	CClientSocket *m_pSocket;
	/**
	* 本线程所使用的连接字符串
	**/
	CString m_strConn;
public:
	virtual BOOL InitInstance();
	virtual int ExitInstance();
	void ProcessSocket();
	CClientSocket* GetSocket(){ return m_pSocket; }

protected:
	DECLARE_MESSAGE_MAP()
	afx_msg void OnSend(WPARAM wParam, LPARAM lParam);
};