vc++学习之15 多线程与聊天室程序的创建

区别:程序和进程、线程(轻量级进程)的概念;

利用window库函数建立一个主线程和子线程的一个轮流执行

#include <windows.h>
#include <iostream.h>

DWORD WINAPI func1proc(LPVOID lpParameter);
int index=10;
void main()
{

	HANDLE hthread1;
	hthread1=CreateThread(NULL,0,func1proc,NULL,0,NULL);//创建一个线程
	CloseHandle(hthread1);//关闭句柄,不关闭线程,减少引用计数,计数为0释放;
	cout<<"main thread is running\n"<<endl;
	Sleep(2000);//主进程睡眠,子进程才能执行,否则子进程不能获得执行;

}
DWORD WINAPI func1proc(
						LPVOID lpParameter   // thread data
						)

{
	cout<<"Thread1 is running!\n"<<endl;
	return 0;
}

本质是程序的执行就是主线程休眠之后,将控制权交给子进程的,子进程然后执行;

多线程注重访问共享变量时的互斥锁的问题

#include <windows.h>
#include <iostream.h>

DWORD WINAPI func1proc(LPVOID lpParameter);
DWORD WINAPI func2proc(LPVOID lpParameter);
int index=0;
int tickets=100;
HANDLE mutex;
void main()
{

	HANDLE hthread1;
	HANDLE hthread2;
	hthread1=CreateThread(NULL,0,func1proc,NULL,0,NULL);//创建一个线程
	hthread2=CreateThread(NULL,0,func2proc,NULL,0,NULL);
	CloseHandle(hthread1);//关闭句柄,不关闭线程,减少引用计数,计数为0释放;
	//while(index++<100)
	//cout<<"main thread is running\n"<<endl;
	mutex=CreateMutex(NULL,false,NULL);//创建互斥锁

	Sleep(2000);//主进程睡眠,子进程才能执行,否则子进程不能获得执行;

}
DWORD WINAPI func1proc(
						LPVOID lpParameter   // thread data
						)

{
	while(true)
	{
		WaitForSingleObject(mutex,INFINITE);//得到mutex互斥对象,互斥对象线程ID设置为该线程ID,

		if (tickets>0)
		{
			Sleep(1);
			cout<<"thread1 sells tickets:"<<tickets--<<endl;
		}
		else
			break;
		ReleaseMutex(mutex);//释放互斥锁,因为他们访问了一个统一的全局变量ticket
	}
	

	return 0;
}
//一旦一个线程正常结束时,就把互斥对象的内部ID设置为0;
DWORD WINAPI func2proc(
					   LPVOID lpParameter   // thread data
					   )
					   
{
	
	while(true)
	{
		WaitForSingleObject(mutex,INFINITE);
		Sleep(1);
		if (tickets>0)
		{
			cout<<"thread2 sells tickets:"<<tickets--<<endl;
		}
		else
			break;
		ReleaseMutex(mutex);
	}

	return 0;
}



c创建一个机遇对话框的聊天窗口;

首先设计好dialog窗口 包含2个组框,2个编辑窗口。一个按钮,一个IP编辑窗口;

2,然后在BOOL CChatApp::InitInstance()中添加标准socket的绑定函数,注意头问价加入socket。h

BOOL CChatApp::InitInstance()
{
	if (!AfxSocketInit())
	{
		AfxMessageBox("加载套接字失败!");
			return FALSE;
	}

3在CChatDlg类里面添加成员变量和成员函数,并在OnInitDialog()调用次初始化函数;

BOOL CChatDlg::InitSocket()
{
	m_socket=socket(AF_INET,SOCK_DGRAM,0);
	if (INVALID_SOCKET==m_socket)
	{
		MessageBox("套接字创建失败");
		return FALSE;
	}
	SOCKADDR_IN addrsock;
	addrsock.sin_addr.S_un.S_addr=htonl(INADDR_ANY);
	addrsock.sin_family=AF_INET;
	addrsock.sin_port=6000;
	//bind到IP和端口上;
	int retval;
	retval=bind(m_socket,(sockaddr*)&addrsock,sizeof(sockaddr));
	if (SOCKET_ERROR==retval)
	{
		closesocket(m_socket);
		MessageBox("套接子绑定失败");
		return FALSE;
	}
	
	return TRUE;

}


3创建线程的函数,因为createthread函数只能传入一个参数,所以利用传入结构体指针形式传入2个参数;

定义结构体:

struct RecvParm
{
	SOCKET sock;
	HWND hwdn;

};


初始化,并调用创建线程函数(CChatDlg::OnInitDialog())

RecvParm *pRecvParam=new RecvParm;//定义一个将要传入到Createthread里面的参数
	pRecvParam->sock=m_socket;//初始化socket
	pRecvParam->hwdn=m_hWnd;//和窗口有关的都一个一个变量保存窗口的句柄
	HANDLE hThread=CreateThread(NULL,0,RecvProc,(LPVOID)pRecvParam,0,NULL);
	CloseHandle(hThread);//关闭句柄,减少计数;

实现线程处理函数RecvProc()定义为起一个成员函数,注意此处为静态函数,因为不是的话,会产生一个参数传递错误;



此聊天窗口程序没有调通;不知为什么窗口不显式输入内容

原文地址:https://www.cnblogs.com/HuaiNianCiSheng/p/3074715.html