3

在我的一个程序中,有多个客户端,每个客户端都有自己的缓冲区。在一个无限循环中,我检查是否有任何客户端有任何数据要写入磁盘。如果是这样,那么我也这样做并继续。

现在,因为客户端写入的数据实际上不在我的控制范围内(一些计算的结果),所以我需要一个动态缓冲区。所以伪代码看起来像这样:

//If data is ready
//Append(client_id, line)

void Append(int client_id, char *line) {
   if(client_id.buffer == NULL) {
      buffer = (char*)malloc(BUFFERSIZE * sizeof(char));
      //Copy line into buffer
   } else {
      //Realloc the buffer if insufficient space and append this
      //line to the existing buffer
   }
}

或者另一种方法是使用简单的消息队列。我会继续将任何消息(字符串)添加到现有队列中,然后将它们读出。还有其他更好的方法吗?

4

1 回答 1

3

我可能没有完全理解您的架构,但我的理解是客户端通过传递其 ID 和 char * 来调用您,并希望您将其写入磁盘。

您是否有理由必须复制原始缓冲区?通过这样做,您可以将所有内容两次保存在内存中,并有机会搞乱内存管理。如果可能,只需使用原始缓冲区即可。

这里发生了一些线程吗?如果这都是单线程的(至少从这个“服务器”代码的角度来看......一个线程来轮询和写入结果),你真的不需要 FIFO,因为事情只会按照你轮询的顺序发生客户。如果有一个(或多个)线程来轮询客户端和一个单独的线程来写入结果,那么 FIFO 是组织线程通信的好方法。

于 2010-02-02T03:48:33.400 回答