c++ - c++中tcp服务器中的多线程

标签 c++ multithreading tcp

我已经用 C++ 为多线程 tcp 服务器编写了这个类 .. 并通过::编译

g++ -o server server.cpp -lpthread

但是我收到以下错误::

invalid conversion from "void*" to "void* (*)(void*)"
initializing argument 3 of "int pthread_create(pthread_t*, const pthread_attr_t*, void* (*)(void*), void*)"

我该怎么办??我的代码::

#include "PracticalSocket.h" 
#include <iostream>          
#include <cstdlib>           
#include <pthread.h>         
using namespace std;

class MultiThreadedServer{

private:
static const int RCVBUFSIZE = 1024;
string agent_ip;
int agent_port;

public:

string startServer(unsigned short port, string agentIP, int agentPort)
{
agent_ip = agentIP;
agent_port=agentPort;

try 
{
    TCPServerSocket servSock(port);   // Socket descriptor for server  

    for (;;) 
    {   
        // Create separate memory for client argument  
        TCPSocket *clntSock = servSock.accept();  
        pthread_t threadID;              
        if (pthread_create(&threadID, NULL, (void*) &ThreadMain,(void *) &clntSock) != 0) 
        {
            cerr << "Unable to create thread" << endl; 
            exit(1);
        }

    }
} 
catch (SocketException &e)
{
    cerr << e.what() << endl;
    exit(1);
}
// NOT REACHED
}


// TCP client handling function
void static HandleTCPClient(TCPSocket *sock) 
{
cout << "Handling client ";
try 
{
    cout<<"Foreign address: "<< sock->getForeignAddress() << ":";
} 
catch (SocketException &e) 
{
    cerr << "Unable to get foreign address" << endl;
}
try 
{
    cout<<"Foreign port: "<< sock->getForeignPort();
} 
catch (SocketException &e)
{
    cerr << "Unable to get foreign port" << endl;
}
cout << " with thread " << pthread_self() << endl;

char echoBuffer[RCVBUFSIZE];
int recvMsgSize;
while ((recvMsgSize = sock->recv(echoBuffer, RCVBUFSIZE)) > 0) 
{
    cout<<"echoBuffer::::"<<echoBuffer;
    //sock->send(echoBuffer, recvMsgSize);
}
   // Destructor closes socket
 }

 static void ThreadMain(void *clntSock)
 {
// Guarantees that thread resources are deallocated upon return  
pthread_detach(pthread_self()); 

// Extract socket file descriptor from argument  
HandleTCPClient((TCPSocket *) clntSock);

delete (TCPSocket *) clntSock;
//return NULL;
 }



 };

最佳答案

你可以直接使用方法名而不用强制转换:

pthread_create(&threadID, NULL, ThreadMain,(void *) &clntSock)

此外,该方法需要返回 void* 而不是 void:

static void* ThreadMain(void *clntSock)

关于c++ - c++中tcp服务器中的多线程,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/8821758/

相关文章:

c++ - 浮点精度未格式化为字符串

C++编程数组以查找范围内的整数个数

sockets - socket recv() 是否强制刷新 socket send() 缓冲区?

c++ - 如何不使用 else 语句制作 if 语句 "link up"

c++ - 如何在 C++ 中的原始线程中执行回调?

java - 在不影响 gui 其余部分的情况下运行后台作业

.net - 注册 CancellationToken.None 是否安全?

ios - 中央调度、操作队列、异步、 View 将和确实消失

c - 创建服务器/客户端 TCP/IP 程序时遇到问题

c++ - 将加密层添加到我的 TCP 客户端/服务器应用程序的最直接方法是什么?