我正在尝试使用POSIX消息队列将消息从子进程发送到父进程。在使用fork((创建子级之前，我创建了消息队列。我的代码应该从链表中提取单词并将其发送给父级。然而，当我调用mq_send函数来发送数据时，程序会卡在函数中，试图从控制台获取输入，并且从未停止。我已经解决这个问题一天多了，我不知道怎么做。我检查了代码的其他部分，它们都能工作。只有mq_send函数会导致问题。有人能告诉我这里出了什么问题吗？也许我错过了什么。代码如下。
注意：此处不能包含所有代码。这里只有与问题相关的部分。此外，这是我在stackoverflow中的第一个问题，因此我对可能出现的格式错误感到抱歉。
编辑：代码无法编译，因为我没有添加所有部分。我的问题只是基于发送消息的代码的最后一个while循环。这就是代码被卡住的地方。
#include <stdio.h>
#include <stdlib.h>
#include <stddef.h>
#include <math.h>
#include <string.h>
#include <sys/types.h>
#include <mqueue.h>
#include <sys/wait.h>
#include <fcntl.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <unistd.h>
struct Node {
char value[1024];
int count;
struct Node* next;
};
struct dataPackage {
char word[1024];
int count;
};
int main(int argcount, char** argvalues) {
struct Node* headList[atoi(argvalues[1])]; // an array to hold linked lists
// creating fileCount number of linked lists and storing them
for ( int i = 0; i < atoi(argvalues[1]); i++ ) {
headList[i] = NULL;
}
// creating message queues
mqd_t mqList[fileCount];
char queueNames[5][1024];
int n;
// creating different names for different message queues
strcpy(queueNames[0], "/queue1");
strcpy(queueNames[1], "/queue2");
strcpy(queueNames[2], "/queue3");
strcpy(queueNames[3], "/queue4");
strcpy(queueNames[4], "/queue5");
// creating the message queues
for (int i = 0; i < atoi(argvalues[1]); i++ ) {
mqList[i] = mq_open(queueNames[i], O_RDWR | O_CREAT, 0666, NULL );
printf("%in", mqList[i]);
}
// creating child processes to process input files
for (int i = 0; i < atoi(argvalues[1]); i++ ) {
// creating a child process
pid_t pid = fork();
// child processes process seperate files
if (pid == 0 ) {
//printf("Before file processn");
// processing the file and creating the sorted linked lists
processFile(fileNames[i], &headList[i]);
// send linked list contents to parent process below
struct dataPackage package;
struct Node* tempHead = headList[i];
while (tempHead != NULL) {
// creating a package to send it to the parent process
package.count = tempHead->count;
strcpy(package.word, tempHead->value);
// !!!!!this is the part where the program gets stuck!!!!!!!!
n = mq_send(mqList[i], (char*) &package, sizeof(struct dataPackage), 0);
tempHead = tempHead -> next;
}
// creating a message that will indicate the end of message queue
package.count = -10;
strcpy(package.word, "stop");
n = mq_send(mqList[i], (char *) &package, sizeof(struct dataPackage), 0);
exit(0);
}
else {
wait(NULL);
}
}
我没有看到mq_receive调用。系统施加了一个队列限制，一旦消息队列建立，您应该能够通过执行cat/dev/mqueue/mymq之类的操作来查看该限制。也就是说，我会检查你是否正确使用了你的信息。我看到您的代码所做的是生成与argvalues[1]中的值一样多的子级，具有子级mq_send，但父级只是等待子级死亡而不消耗消息。
https://linux.die.net/man/7/mq_overview
行
struct Node* headList[argvalues[1]];
让我想知道你想要实现什么。argvalues[1]是指向字符的指针，而不是数字。你的编译器应该告诉你这一点。
如果你想把第一个参数转换成一个数字，你应该使用类似的东西
int count;
if (sscanf(argvalues[1], "%d", &count) != 1) {
/* does not look like a number */
exit(1);
}
/* use count */
确保您尝试访问的队列中没有满消息。
使用mq_getattr()和mq_curmsgs来确定当前消息数。