在网络程序中使用VC2012中使用C++ 11标准的thread时,碰到下面奇怪的事:
(1) 使用thread,但是不使用全using namespace std,而是std::thread,则结果正常。代码及结果如下所示
#include <stdio.h>
#include <Winsock2.h> #include <thread> #pragma comment(lib, "ws2_32.lib") //using namespace std;
void Receive(SOCKET sockConn, const char *sendBuf)
{ char szSendBuffer[2048]; sprintf_s(szSendBuffer, "%s", sendBuf); send(sockConn,szSendBuffer,strlen(szSendBuffer)+1,0);// 发送消息到客户端 while (1) { char recvBuf[2048]; int iCode = recv(sockConn,recvBuf,2048,0); if (iCode && iCode!=SOCKET_ERROR)// 接受客户端消息 { printf("%s\n",recvBuf); sprintf_s(szSendBuffer, "Have processed..."); send(sockConn, szSendBuffer, strlen(szSendBuffer)+1, 0); } else { Sleep(0); } } } void main()
{ WORD wVersionRequested; WSADATA wsaData; int err; wVersionRequested = MAKEWORD( 2, 2 );
err = WSAStartup( wVersionRequested, &wsaData );
if ( err != 0 ) { return; } if ( LOBYTE( wsaData.wVersion ) != 2 ||
HIBYTE( wsaData.wVersion ) != 2 ) { WSACleanup( ); return; } SOCKET sockSrv=socket(AF_INET,SOCK_STREAM,0); SOCKADDR_IN addrSrv;
addrSrv.sin_addr.S_un.S_addr=htonl(INADDR_ANY); addrSrv.sin_family=AF_INET; addrSrv.sin_port=htons(6767); bind(sockSrv,(SOCKADDR*)&addrSrv,sizeof(addrSrv));// 绑定端口
listen(sockSrv,5);
SOCKADDR_IN addrClient;// 连接上的客户端ip地址
int len=sizeof(SOCKADDR_IN); int iMaxClientNum = 20; std::thread clients[20]; while(1) { SOCKET sockConn=accept(sockSrv,(SOCKADDR*)&addrClient,&len);// 接受客户端连接,获取客户端的ip地址 char sendBuf[50]; sprintf(sendBuf,"Welcome %s to here!",inet_ntoa(addrClient.sin_addr));// 组合消息发送出去 printf("%s\n",sendBuf); // Receive(sockConn, sendBuf); clients[20-iMaxClientNum] = std::thread(&Receive, sockConn, sendBuf); clients[20-iMaxClientNum].detach(); if (iMaxClientNum-- <= 0) { break; } //closesocket(sockConn);//断开连接 } system("pause"); } (2) 使用thread头文件,并且使用using namespace std。则accept函数为非堵塞调用(未等待客户端的连接而直接往下执行)。代码如所示: |
|