0

当任务涉及套接字时，我无法使用 std::async 让任务并行执行。

我的程序是一个用标准 C++ 为 Linux 编写的简单 TCP 套接字服务器。当客户端连接时，会打开一个专用端口并启动单独的线程，因此每个客户端都在自己的线程中进行服务。

客户端对象包含在映射中。

我有一个向所有客户广播消息的功能。我最初是这样写的：

//  ConnectedClient is an object representing a single client
//  ConnectedClient::SendMessageToClient opens a socket, connects, writes, reads response and then closes socket
//  broadcastMessage is the std::string to go out to all clients

//  iterate through the map of clients
map<string, ConnectedClient*>::iterator nextClient;
for ( nextClient = mConnectedClients.begin(); nextClient != mConnectedClients.end(); ++nextClient )
{
    printf("%s\n", nextClient->second->SendMessageToClient(broadcastMessage).c_str());

}

我已经对此进行了测试，它一次可以与 3 个客户端一起使用。消息到达所有三个客户端（一次一个），响应字符串在此循环中打印 3 次。但是，它很慢，因为消息一次只发送给一个客户端。

为了提高效率，我希望利用 std::async 为每个客户端异步调用 SendMessageToClient 函数。我像这样重写了上面的代码：

vector<future<string>> futures;

//  iterate through the map of clients
map<string, ConnectedClient*>::iterator nextClient;
for ( nextClient = mConnectedClients.begin(); nextClient != mConnectedClients.end(); ++nextClient )
{   
    printf("start send\n"); 
    futures.push_back(async(launch::async, &ConnectedClient::SendMessageToClient, nextClient->second, broadcastMessage, wait));
    printf("end send\n");

}   

vector<future<string>>::iterator nextFuture;
for( nextFuture = futures.begin(); nextFuture != futures.end(); ++nextFuture )
{
    printf("start wait\n");
    nextFuture->wait();
    printf("end wait\n");
    printf("%s\n", nextFuture->get().c_str());
}

当地图中只有一个客户端时，上面的代码按预期运行。您很快看到“开始发送”，然后是“结束发送”，然后是“开始等待”，然后是 3 秒后（我在客户端响应端有 3 秒睡眠来测试这个），您会看到来自套接字的跟踪读取响应进来的函数，然后你会看到“结束等待”

问题是当地图中有多个客户端时。在打开并连接到套接字的 SendMessageToClient 函数部分中，它在下面标识的代码中失败：

    //  connected client object has a pipe open back to the client for sending messages
int clientSocketFileDescriptor;
clientSocketFileDescriptor = socket(AF_INET, SOCK_STREAM, 0);


//  set the socket timeouts  
    //  this part using setsockopt is omitted for brevity

    //  host name
struct hostent *server;
server = gethostbyname(mIpAddressOfClient.c_str());

if (server == 0) 
{
   close(clientSocketFileDescriptor);
    return "";
}

//
struct sockaddr_in clientsListeningServerAddress;
memset(&clientsListeningServerAddress, 0, sizeof(struct sockaddr_in)); 

clientsListeningServerAddress.sin_family = AF_INET;
bcopy((char*)server->h_addr, (char*)&clientsListeningServerAddress.sin_addr.s_addr, server->h_length);
clientsListeningServerAddress.sin_port = htons(mPortNumberClientIsListeningOn);

    //  The connect function fails !!!
if ( connect(clientSocketFileDescriptor, (struct sockaddr *)&clientsListeningServerAddress, sizeof(clientsListeningServerAddress)) < 0 )
{
    //  print out error code
            printf("Connected client thread: fail to connect %d \n", errno);
    close(clientSocketFileDescriptor);
    return response;
}

输出内容为：“已连接的客户端线程：无法连接 4”。

我查看了这个错误代码，它是这样解释的：

#define EINTR            4      /* Interrupted system call */

我在互联网上四处搜索，我发现的只是一些关于系统调用被信号中断的引用。

有谁知道为什么当我一次调用一个发送消息函数时这会起作用，但是当使用异步调用发送消息函数时它会失败？有没有人有不同的建议我应该如何向多个客户发送消息？

4

1 回答 1

0

首先，我会尝试处理 EINTR 问题。connect ( ) 已被中断（这是 EINTR 的含义）并且不会再次尝试，因为您正在使用和异步描述符。在这种情况下，我通常做的是重试：我将函数（在这种情况下为连接）包装在一个 while 循环中。如果连接成功，我会退出循环。如果失败，我检查 errno 的值。如果是 EINTR 我再试一次。请注意，还有其他值得重试的 errno 值（EWOULDBLOCK 就是其中之一）

于 2014-04-12T08:33:11.800 回答