随笔-5  评论-1  文章-0  trackbacks-0

 

1.阻塞模式
    会造成线程阻塞的有下列四种操作:
(
1) 接受连接请求:accept()
(
2) 接受数据:recv(),recvfrom()
(
3) 请求连接:connect()
(
4) 发送数据:send(),sendto()
    其中1、2最容易发生阻塞。
    
2、多线程的阻塞模式
class CServerDlg : public CDialog
{
    SOCKET m_ClientSock;
    SOCKET m_ServerSock;
    HANDLE m_RecvThread;
    HANDLE m_AcceptThread;
    .
    friend  DWORD WINAPI RecvThreadPro(LPVOID LpP);
    friend  DWORD WINAPI AcceptThreadPro(LPVOID LpP);
};
//创建线程
BOOL CServerDlg::OnInitDialog()
{
    
    
//创建线程
    DWORD ThreadID;
    m_RecvThread 
= CreateThread(NULL, 0, RecvThreadPro, this, CREATE_SUSPENDED, &ThreadID);
    m_AcceptThread 
= CreateThread(NULL, 0, AcceptThreadPro, this, CREATE_SUSPENDED, &ThreadID);
    
int Count = ResumeThread(m_AcceptThread);
    
}
//接收数据线程
DWORD WINAPI RecvThreadPro(LPVOID LpP)
{
    CServerDlg 
*pServer = (CServerDlg *)LpP;
    ZeroMemory(buf, 
20);
    
int nLen = recv(pServer->m_ClientSock, buf, 200);
    
if(SOCKET_ERROR == nLen) 
        AfxMessageBox(
"Recv Failed!");
    
else
        AfxMessageBox(buf);
    
return 0;
}
//接受客户端请求线程
DWORD WINAPI AcceptThreadPro(LPVOID LpP)
{
    CServerDlg 
*pServer = (CServerDlg *)LpP;
    
struct sockaddr ClientAddr;
    
int len = sizeof(SOCKADDR_IN);
    pServer
->m_ClientSock = accept(pServer->m_ServerSock, &ClientAddr, &len);
    
if(SOCKET_ERROR == pServer->m_ClientSock)
        AfxMessageBox(
"Accept Failed!");
    
return 0;
}
//结束线程
void CServerDlg::OnClose() 
{
    
// TODO: Add your message handler code here and/or call default
    
//结束AcceptThread
    DWORD ThreadState;
    GetExitCodeThread(m_AcceptThread, 
&ThreadState);
    
if(ThreadState == STILL_ACTIVE)
    {
        
//TerminateThread(m_hThread, 0);
        WaitForSingleObject(m_AcceptThread,0xffffffff); 
        CloseHandle(m_AcceptThread); 
    }
    
//结束RecvThread
    GetExitCodeThread(m_RecvThread, &ThreadState);
    
if(ThreadState == STILL_ACTIVE)
    {
        
//TerminateThread(m_RecvThread, 0);
        WaitForSingleObject(m_RecvThread,0xffffffff); 
        CloseHandle(m_RecvThread); 
    }
    
    
    CDialog::OnClose();
}
posted on 2009-07-26 11:09 yunboy 阅读(480) 评论(0)  编辑 收藏 引用 所属分类: 网络通信

只有注册用户登录后才能发表评论。
网站导航: 博客园   IT新闻   BlogJava   知识库   博问   管理