正文

第15课多线程与网络编程2007-05-01 15:39:00

【评论】 【打印】 【字体: 】 本文链接:http://blog.pfan.cn/bclz/25442.html

分享到:

1.多线程介绍,略2.一个简单的多线程程序MSND中参数[in]和[out]的含义要注意#include <windows.h>#include <iostream.h> DWORD WINAPI Fun1Proc(  LPVOID lpParameter   // thread data); DWORD WINAPI Fun2Proc(  LPVOID lpParameter   // thread data);int index=0;int tickets=100;HANDLE hMutex;互斥对象的句柄void main(){HANDLE hThread1;HANDLE hThread2;hThread1=CreateThread(NULL,0,Fun1Proc,NULL,0,NULL);创建线程1hThread2=CreateThread(NULL,0,Fun2Proc,NULL,0,NULL);创建线程2CloseHandle(hThread1);关闭线程的句柄,为什么要关闭?它将线程的使用计数减1CloseHandle(hThread2);这样当线程结束时,线程内核对象被释放,否则只有当进程结束,才释放线程的内核对象/*while(index++<1000)  cout<<"main thread is running"<<endl;*///hMutex=CreateMutex(NULL,TRUE,NULL);将第二个参数设为true后,互斥对象的计数加1hMutex=CreateMutex(NULL,TRUE,"tickets");此段代码可以让系统只一份实例在运行!if(hMutex){  if(ERROR_ALREADY_EXISTS==GetLastError())  {   cout<<"only instance can run!"<<endl;   return;  }}WaitForSingleObject(hMutex,INFINITE);此代码也将互斥对象的计数加1ReleaseMutex(hMutex);所以要释放两次互斥对象ReleaseMutex(hMutex);Sleep(4000);睡眠4000毫秒// Sleep(10);} DWORD WINAPI Fun1Proc(  LPVOID lpParameter   // thread data){/*while(index++<1000)  cout<<"thread1 is running"<<endl;*//*while(TRUE){  //ReleaseMutex(hMutex);  WaitForSingleObject(hMutex,INFINITE);等待互斥对象的到来,到来后将互斥对象的计数加1  if(tickets>0)  {   Sleep(1);   cout<<"thread1 sell ticket : "<<tickets--<<endl;  }  else   break;  ReleaseMutex(hMutex);释放互斥对象,将其计数减1,这样可以保证,这两句话之间 的代码!的执行连续性!}*/ WaitForSingleObject(hMutex,INFINITE);cout<<"thread1 is running"<<endl;return 0;} DWORD WINAPI Fun2Proc(  LPVOID lpParameter   // thread data){/*while(TRUE){  //ReleaseMutex(hMutex);  WaitForSingleObject(hMutex,INFINITE);  if(tickets>0)  {   Sleep(1);   cout<<"thread2 sell ticket : "<<tickets--<<endl;  }  else   break;  ReleaseMutex(hMutex);}*/WaitForSingleObject(hMutex,INFINITE);cout<<"thread2 is running"<<endl;return 0;} 3.多线程聊天程序  1.加载套接字库在InitInstance()中,调用AfxSocketInit(),此时可以不加载库文件,但要加入Afxsock.h"头文件  2.在CChatDlg中创建成员变量m_socket,然后增加一个成员函数,IniSocket(),在其中完成m_socket的初始化和绑定。在OnInitDialog中调用InitSocket完成初始化工作。  3.定义一个结构体,包含两个参数,sock和hwnd,在OnInitDialog()中初始化这个结构体的对象。  4.创建一个线程,CreateThread(),须将线程函数RecvProc定义为静态的或者全局函数。    ::PostMessage()完成将收到的数据发送给对话框。用自定义的消息,自定义的消息如何写?以前说过,参考下面的代码。注意要将EDitBox的MultiLine属性选上。      在ChatDlg.h中#define WM_RECVDATA  WM_USER+1afx_msg void OnRecvData(WPARAM wParam,LPARAM lParam);    在ChatDlg.cpp中ON_MESSAGE(WM_RECVDATA,OnRecvData)然后实现这个函数void CChatDlg::OnRecvData(WPARAM wParam,LPARAM lParam){CString str=(char*)lParam;CString strTemp;GetDlgItemText(IDC_EDIT_RECV,strTemp);str+="\r\n";str+=strTemp;SetDlgItemText(IDC_EDIT_RECV,str);}     最后在DWORD WINAPI CChatDlg::RecvProc(LPVOID lpParameter)中调用 ::PostMessage(hwnd,WM_RECVDATA,0,(LPARAM)tempBuf);//不能用SendMessage()    4.对发送按纽的响应代码:void CChatDlg::OnBtnSend() {// TOD Add your control notification handler code hereDWORD dwIP;((CIPAddressCtrl*)GetDlgItem(IDC_IPADDRESS1))->GetAddress(dwIP); SOCKADDR_IN addrTo;addrTo.sin_family=AF_INET;addrTo.sin_port=htons(6000);addrTo.sin_addr.S_un.S_addr=htonl(dwIP); CString strSend;GetDlgItemText(IDC_EDIT_SEND,strSend);sendto(m_socket,strSend,strSend.GetLength()+1,0,  (SOCKADDR*)&addrTo,sizeof(SOCKADDR));SetDlgItemText(IDC_EDIT_SEND,"");}

阅读(2253) | 评论(0)


版权声明:编程爱好者网站为此博客服务提供商,如本文牵涉到版权问题,编程爱好者网站不承担相关责任,如有版权问题请直接与本文作者联系解决。谢谢!

评论

暂无评论
您需要登录后才能评论,请 登录 或者 注册