基于这个答案，我正在模拟有两个作家和一个读者。
因此，我创建了两个管道，我为每个管道写入一个实际的字符串和一个字符串，通知读者他已经完成了这个作家。
但是，它只会读取第一个字符串，有时还会读取第二个管道的结束字符串。
我错过了什么？
读者.c
int main() {
int w_no = 2;
int fd[w_no];
char * myfifo[w_no];
fill_names(myfifo, w_no);
print_names(myfifo, w_no);
struct pollfd fdtab[w_no];
int done[w_no];
/* create the FIFO (named pipe) */
int i;
for (i = 0; i < w_no; ++i) {
//fd[i] = open(myfifo[i], O_RDONLY);
while( (fd[i] = open(myfifo[i], O_RDONLY)) == -1);
fdtab[i].fd = fd[i];
fdtab[i].events = POLLIN;
fdtab[i].revents = 0;
done[i] = 0;
}
char buffer[1024];
ssize_t bytes;
printf("Edw prinn");
while(not_all_done(done, w_no)) {
int retpoll = poll(fdtab, w_no, 300);
if(retpoll != 0) {
if (retpoll == -1) {
perror("poll");
break;
}
for(i = 0; i < w_no; ++i) {
if(fdtab[i].revents & POLLIN) {
printf("Edw %d %d %d %dn", i, retpoll, fdtab[i].revents, POLLIN);
//read the written pipe
while((bytes = read(fdtab[i].fd, buffer, sizeof(buffer))) > 0)
printf("Read |%s| %d %d %dn", buffer, retpoll, fdtab[i].revents, POLLIN);
if(!strcmp(buffer, "++"))
done[i] = 1;
}
}
} else if (retpoll == 0) {
/* the poll has timed out, nothing can be read or written */
printf("timeout from writern");
break;
}
}
for (i = 0; i < w_no; ++i) {
close(fd[i]);
}
free_names(myfifo, w_no);
return 0;
}
作家.c
int main() {
int w_no = 2;
int fd[w_no];
char * myfifo[w_no];
fill_names(myfifo, w_no);
print_names(myfifo, w_no);
/* create the FIFO (named pipe) */
int i;
int bytes;
for (i = 0; i < w_no; ++i) {
mkfifo(myfifo[i], 0666);
fd[i] = open(myfifo[i], O_WRONLY);
while( (bytes = write(fd[i], "Hi+", sizeof("Hi+"))) == 3);
printf("wrote %d bytes, %dn", bytes, sizeof("Hi+"));
while( (bytes = write(fd[i], "++", sizeof("++"))) == 2);
printf("wrote %d bytes, %dn", bytes, sizeof("++"));
}
for (i = 0; i < w_no; ++i) {
close(fd[i]);
unlink(myfifo[i]);
}
free_names(myfifo, w_no);
return 0;
}
示例输出：
/tmp/myfifo_0
/tmp/myfifo_0
/tmp/myfifo_1
/tmp/myfifo_1
wrote 4 bytes, 4
wrote 3 bytes, 3
wrote 4 bytes, 4
Edw prin
wrote 3 bytes, 3
Edw 0 2 17 1
Read |Hi+| 2 17 1
Edw 1 2 1 1
Read |Hi+| 2 1 1
^C
编辑
当Hi+字符串到达时，bytes的值为 7。
我尝试发送的结束字符串是 ++ ，但它没有被读取。
EDIT_2
char* concat(char *s1, char *s2) {
char *result = malloc(strlen(s1) + strlen(s2) + 1); //+1 for the null-terminator
//in real code you would check for errors in malloc here
strcpy(result, s1);
strcat(result, s2);
return result;
}
void fill_names(char* f[], int n) {
int i = 0;
char * buf = "/tmp/myfifo_";
char str[15];
for (; i < n; ++i) {
sprintf(str, "%d", i);
f[i] = concat(buf, str);
}
}
想法
也许编写器在从管道读取数据之前关闭并取消链接管道？如果是这样，我应该怎么做才能防止这种情况发生？
如果在此之前放一个sleep(10)，它不会改变行为，它只会读取前两个字符串，但它会花费更多时间，然后它会挂断（因为它等待结束字符串）。
EDIT_3
我还有一个 main.c，它执行读者和作家。
字符串编写中存在问题：
while( (bytes = write(fd[i], "Hi+", sizeof("Hi+"))) == 3);
printf("wrote %d bytes, %dn", bytes, sizeof("Hi+"));
while( (bytes = write(fd[i], "++", sizeof("++"))) == 2);
printf("wrote %d bytes, %dn", bytes, sizeof("++"));
这里你发送 7 个字节：H i + + + ，因为字符串 lital 的sizeof()包含空终止符。
顺便说一下，只要可以写入 3 个字节，while((bytes=write(...))==3)就会循环。这不会在这里发生，因为您的写作也存在空终止符。 但最好删除封闭while.
由于管道是一个流，因此无法保证您将在两个不同的读取中接收字节。 事实上，你所有的解释和日志都显示你一次收到所有7个字节。
但是，您可以使用printf("Read |%s| %d %d %dn"...)打印内容：刺穿包含"\0"的字符串的结果是未定义的。 在您的情况下，打印的字符串将被截断。因此，仅打印"Hi+"，但"\0++"仍隐藏在缓冲区中。
顺便说一下，while((bytes = read(...)) > 0)可以循环打印几次。 这本身不是问题。只是如果写入器及时发送数据，连续读取可能会暂时锁定其他管道的读取。 一般来说，在极速程序中，人们更喜欢从每个准备好的管道中读取一点点。
检查结束字符串
if(!strcmp(buffer, "++"))
done[i] = 1;
在大多数情况下可能不会成功。 您不确定一端的一次写入是否会导致另一端的读取。 因此，您的"++"字符串不一定位于缓冲区的开头。 它可以在缓冲区中的任何位置，因此您必须搜索它。 它甚至可以在两个连续的读取之间拆分。
顺便说一下，可能是read()只找到部分数据（例如："i+"），而没有终止 null。 如果假设缓冲区中存在有效字符串，则可能会有缓冲区溢出的风险。
建议：
如果您的命名管道用于处理文本数据，我建议您在要发送的每组数据的末尾添加一个'n'，并将字符串写入管道而不终止 null：
bytes = write(fd[i], "Hi+n", sizeof("Hi+n")-1);
然后，当你阅读时，你可以像管理一个字符串一样管理缓冲区：总是添加尾随的 0：
bytes = read(fdtab[i].fd, buffer, sizeof(buffer)-1); // leave a byte for terminator
if (bytes>0) {
buffer[bytes]=0; // end of string.
// process the string in the buffer
}
else if (bytes==0) {
done[i]=1;
}
最后，为了识别您的结束命令，假设您将其发送为"++"，有三种可能性：
if (strncmp(buffer,"++n",3)==0 /* it's at the beginning of the buffer */
|| strstr(buffer, "n++n") ) /* it's in the middle but not a subpart and preceded by a packet separator */
done[i]=1;
但是您还必须检查两个读取之间的拆分。 这更微妙，但我相信你能找到一种方法;-）
尝试打印您在阅读器程序中读取的字节数。我的猜测是，您读取的字节比您想象的要多，但是在打印字符串时，您只会获得第一个终止零之前的字节。
您是否打算在命名管道上发送终止零？也许发送其他东西（例如换行符）会更好？