Как ускорить работу сокетов?

 listener = socket(AF_INET, SOCK_STREAM, 0);
 fcntl(listener, F_SETFL, O_NONBLOCK);

//------------------------------------------------------------------------------
#include <winsock>
#include <stdio.h>
//------------------------------------------------------------------------------
int main(int argc, char* argv[])
{
    WSADATA wsa_data;
    if (WSAStartup(0x101, &wsa_data) || wsa_data.wVersion != 0x101) return -1;
 
    SOCKET s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (s == INVALID_SOCKET) return -1;
 
    SOCKADDR_IN sa;
    sa.sin_family = AF_INET;
    sa.sin_port = htons(2000);
    sa.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
 
    printf("wait for server...\n");
 
    while (true)
    {
        int connect_res = connect(s, (SOCKADDR *)&sa, sizeof(sa));
        if (!connect_res) break;
 
        Sleep(250);
    }
 
    printf("connected\n");
 
    int messages_count = 100000;
    char message[1024];
 
    DWORD t = GetTickCount();
 
    for (int i = 0; i < messages_count; i++)
        if (send(s, message, sizeof(message), 0) == SOCKET_ERROR) return -1;
 
    printf("message size: %i\n", sizeof(message));
    printf("nessages count: %i\n", messages_count);
    printf("messages per second: %i\n", messages_count * 1000 / (GetTickCount() - t));
 
    closesocket(s);
 
    WSACleanup();
 
    system("pause");
    return 0;
}

//------------------------------------------------------------------------------
#include <winsock>
#include <stdio.h>
//------------------------------------------------------------------------------
int main(int argc, char* argv[])
{
    WSADATA wsa_data;
    if (WSAStartup(0x101, &wsa_data) || wsa_data.wVersion != 0x101) return -1;
 
    SOCKET s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (s == INVALID_SOCKET) return -1;
 
    SOCKADDR_IN sa;
    sa.sin_family = AF_INET;
    sa.sin_port = htons(2000);
    sa.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
 
    if (bind(s, (SOCKADDR *)&sa, sizeof(sa)) == SOCKET_ERROR) return -1;
    if (listen(s, SOMAXCONN) == SOCKET_ERROR) return -1;
 
    printf("wait for client...\n");
 
    while (true)
    {
        fd_set s_set;
        FD_ZERO(&s_set);
        FD_SET(s, &s_set);
        timeval timeout = {0, 0};
 
        int select_res = select(s + 1, &s_set, 0, 0, &timeout);
        if (select_res == SOCKET_ERROR) return -1;
        if (select_res) break;
 
        Sleep(250);
    }
 
    SOCKET ns;
 
    SOCKADDR_IN nsa;
    int sizeof_nsa = sizeof(nsa);
 
    ns = accept(s, (SOCKADDR *)&nsa, &sizeof_nsa);
    if (ns == INVALID_SOCKET) return -1;
 
    printf("connected...\n");
 
    char buffer[1024];
 
    int data_size = 0;
 
    while (true)
    {
        int recv_res = recv(ns, buffer, sizeof(buffer), 0);
        if (recv_res == SOCKET_ERROR) return -1;
        if (!recv_res) break;
        data_size += recv_res;
    }
 
    printf("data size: %i bytes\n", data_size);
 
    closesocket(ns);
    closesocket(s);
 
    WSACleanup();
 
    system("pause");
    return 0;
}

//------------------------------------------------------------------------------
#include <winsock>
#include <stdio.h>
//------------------------------------------------------------------------------
int main(int argc, char* argv[])
{
    WSADATA wsa_data;
    if (WSAStartup(0x101, &wsa_data) || wsa_data.wVersion != 0x101) return -1;
 
    int messages_count = 3000;
    char message[1024];
 
    DWORD t = GetTickCount();
 
    for (int i = 0; i < messages_count; i++)
    {
        SOCKET s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
        if (s == INVALID_SOCKET) return -1;
 
        SOCKADDR_IN sa;
        sa.sin_family = AF_INET;
        sa.sin_port = htons(2000);
        sa.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
 
        while (true)
        {
            int connect_res = connect(s, (SOCKADDR *)&sa, sizeof(sa));
            if (!connect_res) break;
        }
        if (send(s, message, sizeof(message), 0) == SOCKET_ERROR) return -1;
        closesocket(s);
        
        printf("message %i ok\n", i);
    }
 
    printf("message size: %i\n", sizeof(message));
    printf("nessages count: %i\n", messages_count);
    printf("messages per second: %i\n", messages_count * 1000 / (GetTickCount() - t));
 
    WSACleanup();
 
    system("pause");
    return 0;
}

//------------------------------------------------------------------------------
#include <winsock>
#include <stdio.h>
#include <conio.h>
//------------------------------------------------------------------------------
int main(int argc, char* argv[])
{
    WSADATA wsa_data;
    if (WSAStartup(0x101, &wsa_data) || wsa_data.wVersion != 0x101) return -1;
 
    SOCKET s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (s == INVALID_SOCKET) return -1;
 
    SOCKADDR_IN sa;
    sa.sin_family = AF_INET;
    sa.sin_port = htons(2000);
    sa.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
 
    if (bind(s, (SOCKADDR *)&sa, sizeof(sa)) == SOCKET_ERROR) return -1;
    if (listen(s, SOMAXCONN) == SOCKET_ERROR) return -1;
 
    int data_size = 0;
    int i = 0;
 
    while (!kbhit())
    {
        fd_set s_set;
        FD_ZERO(&s_set);
        FD_SET(s, &s_set);
        timeval timeout = {0, 250};
 
        int select_res = select(s + 1, &s_set, 0, 0, &timeout);
        if (select_res == SOCKET_ERROR) return -1;
        if (select_res)
        {
            SOCKET ns;
 
            SOCKADDR_IN nsa;
            int sizeof_nsa = sizeof(nsa);
 
            ns = accept(s, (SOCKADDR *)&nsa, &sizeof_nsa);
            if (ns == INVALID_SOCKET) return -1;
 
            char buffer[1024];
 
            while (true)
            {
                int recv_res = recv(ns, buffer, sizeof(buffer), 0);
                if (recv_res == SOCKET_ERROR) return -1;
                if (!recv_res) break;
                data_size += recv_res;
            }
 
            closesocket(ns);
 
            printf("message %i ok\n", i++);
        }
    }
 
    printf("data size: %i bytes\n", data_size);
    
    closesocket(s);
 
    WSACleanup();
 
    system("pause");
    return 0;
}