第十七课：多线程 一、概念： 进程：一个进程就是一个运行的程序，它有独立的内存、文件句柄和其他系统资源。当启动一个进程时，操作系统会为此进程建立一个4GB的地址空间，进程是操作系统分配内存地址空间的单位。 线程：是操作系统分配处理器时间的最基本单元。所以一个进程必须包含一个线程，我们称之为主线程。如果需要，进程可以产生更多的线程，让CPU在同一时间执行 不同段落的代码。 二、举例： 1． 在单线程中执行多个死循环： 建立一个控制台工程，加入一个cpp文件，编写如下代码： #include "stdio.h" void fun() { while(1) { printf("thread 2 is rurnning!\n"); } } void main() { fun(); while(1) { printf("thread 1 is running!\n"); } } 此时只能打出thread 2 is rurnning!，因为CPU总是在执行fun函数的代码 。没有机会向下执行其余代码。 2． 在单线程中执行多个死循环： #include "stdio.h" #include "windows.h" DWORD WINAPI fun(LPVOID lpParameter) { while(1) { printf("thread 2 is rurnning!\n"); } } void main() { CreateThread(NULL,0,fun,0,0,0); while(1) { printf("thread 1 is running!\n"); } } 此时“thread 1 is rurnning!”，“thread 2 is rurnning!”都能打出来，两个死循环在同时运行。 三、编写一个聊天程序： 1． 建立一个基于对话框的MFC工程，删除提示用的标签控件。加入一个用于显示聊天对方发来的信息的列表框，一个用于输入输入发送给别人的信息的文本框，一个用于输入IP地址的IP Address控件。 2． 定义一个成员变量 SOCKET m_sockChat; 3． 在对话框中加入一个成员函数InitSocket()，对m_sockChat进行初始化： m_sockChat=socket(AF_INET,SOCK_DGRAM,0); SOCKADDR_IN addrChat; addrChat.sin_family=AF_INET; addrChat.sin_port=htons(3000); addrChat.sin_addr.S_un.S_addr=htonl(INADDR_ANY); bind(m_sockChat,(SOCKADDR*)&addrChat,sizeof(SOCKADDR)); 4． 加入OnOK函数，注释其中的CDialog::OnOK();语句，然后加入代码： CString str; GetDlgItemText(IDC_EDIT1,str); //得到用户在文本框中输入的字符串 SOCKADDR_IN addrDest; addrDest.sin_family=AF_INET; addrDest.sin_port=htons(3000); DWORD dwIP; ((CIPAddressCtrl*)GetDlgItem(IDC_IPADDRESS1))->GetAddress(dwIP); //得到用户在IP地址控件中输入的地址 addrDest.sin_addr.S_un.S_addr=htonl(dwIP); sendto(m_sockChat,str,str.GetLength(), 0,(SOCKADDR*)&addrDest,sizeof(SOCKADDR)); //发送数据到达指定的计算机 SetDlgItemText(IDC_EDIT1,""); //将文本框清空 5． 定义一个结构体，用于向线程函数传递参数： struct RECVPARAM { SOCKET sock; HWND hwnd; }; 6． 在对话框的OnInitDialog()函数中加入： InitSocket(); //初始化socket ((CIPAddressCtrl*)GetDlgItem(IDC_IPADDRESS1))->SetAddress(192,168,8,255); //设置IP地址控件的初始地址 RECVPARAM *precvparam=new RECVPARAM(); precvparam->sock=m_sockChat; precvparam->hwnd =this->m_hWnd; ::CreateThread(NULL,0,recvproc,(LPVOID)precvparam,0,0); //启动一个线程，在线程函数中接收数据 7． 定义线程函数： DWORD WINAPI recvproc(LPVOID lpParameter) { SOCKET sockChat=((RECVPARAM*)lpParameter)->sock; HWND hwnd=((RECVPARAM*)lpParameter)->hwnd; //取出传递进来的参数 detele (RECVPARAM*)lpParameter; char buf[1024]; //定义用于接收数据的缓冲区 SOCKADDR_IN addrSrc; int len,x; char *str; while (1) { memset(buf,0,1024); //清空缓冲区 len=sizeof(SOCKADDR); recvfrom(sockChat,buf,1024,0,(SOCKADDR*)&addrSrc,&len); //接收数据 sprintf(buf,"%s:%s:%d",buf, inet_ntoa(addrSrc.sin_addr),ntohs(addrSrc.sin_port)); //得到对方的IP地址和端口号 x=strlen(buf); str=new char[x+1]; strcpy(str,buf); //将得到的数据转存 ::PostMessage(hwnd,WM_USER+1,0,(LPARAM)str); //向指定的窗口发送消息 } } 8． 在对话框的消息映射表中添加： ON_MESSAGE(WM_USER+1, OnRecvData) 9． 在对话框中添加成员函数OnRecvData： LRESULT CChatDlg::OnRecvData(WPARAM wParam, LPARAM lParam) { ((CListBox*)GetDlgItem(IDC_LIST1))->InsertString(0,(char*)lParam); //将接收到的信息加入列表框中 delete (char*)lParam; //释放在线程中用new分配的空间 return 1; }
评论