Epoll разделение на потоки

#define SERVER_ADDR INADDR_ANY
#define SERVER_PORT 34254
#define MAX_EVENTS  32000
#define EPOLL_SIZE  32000
 
using namespace std;
 
int TcpServer::SetNonBlocking(int sock)
{
    int ret = -1;
    int opts = fcntl(sock, F_GETFL);
    if (opts >= 0)
    {
        opts = (opts | O_NONBLOCK);
        if (fcntl(sock, F_SETFL, opts) >= 0)
        {
            ret = 0;
        }
    }
    return ret;
}
 
TcpServer ::TcpServer()
{
    int MainSock;
    struct sockaddr_in saddr;
    int x;
    int cnt;
    int len;
    int epfd;
    struct epoll_event ev;
    struct epoll_event events[MAX_EVENTS];
    MainSock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
 
    if (MainSock != -1)
    {
        saddr.sin_family = AF_INET;
        saddr.sin_addr.s_addr = INADDR_ANY;
        saddr.sin_port = htons(3425);
        x = 1;
        setsockopt(MainSock, SOL_SOCKET, SO_REUSEADDR, &x, sizeof (x));
        if (bind(MainSock, (struct sockaddr*) &saddr, sizeof (struct sockaddr_in)) == -1)
        {
             perror("bind");
             exit(2);
        }
            listen(MainSock, 800);
            cout << "Работаем \n";
            if ((epfd = epoll_create(EPOLL_SIZE)) != -1)
            {
                ev.events = EPOLLIN;
                ev.data.fd = MainSock;
                if (epoll_ctl(epfd, EPOLL_CTL_ADD, MainSock, &ev) != -1)
                {
                    while (1)
                    {
                        char buf[256] = {""};
                        if ((cnt = epoll_pwait(epfd, events, MAX_EVENTS, -1, NULL)) == -1)
                        {
                            /* Обработка ошибки */
                             printf("Ошибкаn");
                             break;
                        }
                        for (x = 0; x < cnt; x++)
                        {
                            if (events[x].data.fd == MainSock) // if new client
                            {
                                ev.data.fd = accept(MainSock, NULL, 0);
                                if (ev.data.fd == -1)
                                {
                                    /* Обработка ошибки */
                                    printf("Ошибкаn");
                                    continue;
                                }
                                else
                                {
                                    SetNonBlocking(ev.data.fd);
                                    ev.events = EPOLLIN | EPOLLET;
                                    if (epoll_ctl(epfd, EPOLL_CTL_ADD, ev.data.fd, &ev) == -1)
                                    {
                                        close(ev.data.fd);
                                        printf("Ошибка подключения  \n");
                                        continue;
                                    }
                                    printf("Успешно подключён \n");
                                }
                            }
                            else // if clients event
                            {
                                if (events[x].events & EPOLLIN) // if client sended data
                                {
                                    len = recv(events[x].data.fd, buf, 256, 0);
                                    if (len > 0)
                                    {
                                        /* Обработка команды */
                                        send(events[x].data.fd, buf, len, 0);
                                        cout << buf << "\n";
                                    }
                                    else // client disconnected
                                    {
                                        close(events[x].data.fd);
                                        printf("Успешно Отключился \n");
                                    }
                                }
                                else if (events[x].events & (EPOLLHUP | EPOLLERR)) // if client error
                                {
                                    close(events[x].data.fd);
                                }
                            }
                        }
                    }
                }
                close(epfd);
            }
            close(MainSock);
    }
}