vs2013實驗可行：

main函式：

// thre.cpp : 定義控制檯應用程式的入口點。
//


#include "stdafx.h"
#include <stdlib.h>  
#include "serverthread.h"
#include <WINSOCK2.H>
#include <vector>
#pragma comment(lib,"ws2_32.lib")




vector<serverThread*> serverThreads;
void addd(SOCKET server)
{
sockaddr_in clientsock;
int len = sizeof(sockaddr);
while (true)
{
unsigned long ul = 1;
ioctlsocket(server, FIONBIO, (unsigned long *)&ul);//設定成非阻塞模式。  
SOCKET client = accept(server, (sockaddr*)&clientsock, &len);
if (SOCKET_ERROR == client)
{
int b = WSAGetLastError();
if (b == WSAEWOULDBLOCK)
{
//printf("阻塞\n");
}
else if (b == WSAETIMEDOUT)
{
//printf("超時\n");
}
else if (b == WSAENETDOWN)
{
//printf("斷開連線\n");
}
}
else
{
 
ioctlsocket(client, FIONBIO, (unsigned long *)&ul);//設定成非阻塞模式。  
serverThread* ser = new serverThread(client);
serverThreads.push_back(ser);
}
 







}

}


int _tmain(int argc, _TCHAR* argv[])
{
//建立套接字
WORD myVersionRequest;
WSADATA wsaData;
myVersionRequest = MAKEWORD(1, 1);
int err;
err = WSAStartup(myVersionRequest, &wsaData);
if (!err){
printf("已開啟套接字\n");
}
else{
printf("ERROR:巢狀字未開啟!");
return 1;
}


SOCKET server = socket(AF_INET, SOCK_STREAM, 0);
sockaddr_in serversock;
serversock.sin_family = AF_INET;
serversock.sin_port = htons(3000);
serversock.sin_addr.S_un.S_addr = htonl(INADDR_ANY);
::bind(server, (sockaddr*)&serversock, sizeof(sockaddr));
listen(server, 5);




std::thread t(addd, server);
t.join();






for each (serverThread* var in serverThreads)
{
free(var);
}


closesocket(server);
WSACleanup();
 
 

system("pause");
return 0;
}
 

#pragma once




#include <thread>
#include <mutex> 
#include <condition_variable>
 
using namespace std;






class serverThread
{
public:
static bool finish;
static unsigned int num;
int flag_;
int nn;
std::mutex g_mutex;
std::condition_variable g_cond;
std::condition_variable g_cond2;
std::thread sendt;
std::thread recvt;
void sendFun(unsigned int num);
void recvFun(unsigned int num);
serverThread(unsigned int nn) /*sendt(std::bind(&serverThread::sendFun,this,12)),*/ 
{
this->nn = nn;
finish = true;
flag_ = 0;
sendt = thread(std::bind(&serverThread::sendFun, this, nn));
recvt = thread(std::bind(&serverThread::recvFun, this, nn));
sendt.detach();
recvt.detach();
}
~serverThread();


private:


};
 

#include "stdafx.h"
#include "serverthread.h"
#include <WINSOCK2.H>
#pragma comment(lib,"ws2_32.lib")


unsigned int serverThread::num = 0;
bool serverThread::finish = true;
serverThread::~serverThread()
{
finish = false;
closesocket(nn);
}


void serverThread::sendFun(unsigned int num)
{
SOCKET client = nn;
while (finish)
{
std::unique_lock<std::mutex> lg(g_mutex);
while (0 == flag_) {
g_cond.wait(lg);
}
char buf[100] = { 0 };
strcpy_s(buf, 100, "server:server");


int a = send(client, buf, strlen(buf) + 1, 0);

if (SOCKET_ERROR == a)
{
int b = WSAGetLastError();
if (b == WSAEWOULDBLOCK)
{
//printf("阻塞\n");
}
else if (b == WSAETIMEDOUT)
{
//printf("超時\n");
}
else if (b == WSAENETDOWN)
{
//printf("斷開連線\n");
}
}
else
{
printf("%s\n", buf);
flag_ = 0;
g_cond2.notify_one();
}
}
}


void serverThread::recvFun(unsigned int num)
{
SOCKET client = nn;
while (finish)
{
std::unique_lock<std::mutex> lg(g_mutex);
while (100 == flag_) {
g_cond2.wait(lg);
}
char buf[100] = { 0 };
int a = recv(client, buf, 99, 0);
if (SOCKET_ERROR == a)
{
int b = WSAGetLastError();
if (b == WSAEWOULDBLOCK)
{
//printf("阻塞\n");
}
else if (b == WSAETIMEDOUT)
{
//printf("超時\n");
}
else if (b == WSAENETDOWN)
{
//printf("斷開連線\n");
}
}
else
{
printf("%s\n", buf);
flag_ = 100;
g_cond.notify_one();
}
}
}
 

本人菜鳥，歡迎各種提bug。