c - 客户端/服务器中的 write()/read()，C 中的 pthread 应用程序在非主线程上总是返回 -1？

Question

所以，我有这个客户端/服务器应用程序，其中服务器具有生产者/消费者架构。我有两个函数来处理套接字的写入和读取。服务器(生产者)的主线程处理连接，并通过堆栈将套接字描述符传递给第二个线程(消费者)进行处理。

问题是，每当我尝试从与主线程不同的线程 write() 或 read() 套接字时，它总是返回 -1 并导致 Connection Reset by Peer 错误客户端和服务器上的传输端点未连接错误。令人惊讶的是，当从主线程读取/写入套接字时，它完美地工作。

为什么会发生这种情况？这是官方行为吗？我如何使用消费者线程回复客户端？我不相信这是因为我编写的代码，因为消费者线程只调用读/写套接字函数。

如果您怀疑哪一部分可能是罪魁祸首，请让我发布一些代码。

编辑:

typedef struct s_stack {
    int * c_stack;
    int base;
    int top;
    unsigned char is_full;
    unsigned char is_empty;
    int max_size;
} s_stack_t;
s_stack_t stack;

void * producer_routine(void * arguments) {

    /* socket(), bind(), listen(), etc.,
       socket fd on "socket_fd",
       new connection fd on "new_fd" */

    for(;;) {
        new_fd = accept(socket_fd, (struct sockaddr *)&client_addr, &clen);

        pthread_mutex_lock(&mutex);
        while (stack.is_full) {
            pthread_cond_wait(&stack_not_full, &mutex);
        }
        if (stack.is_full){
            push(&stack, new_fd);
            pthread_cond_signal(&stack_not_empty);
        }
        pthread_mutex_unlock(&mutex);
    }
    close(new_fd);
}

void * consumer_routine(void *args) {
    for(;;) {
        int socket_fd;
        /* same mutex lock as above, just reversed, pop to socket_fd */
        write_a_message_to_client(socket_fd);
    }
}

int main() {
    stack_init(&stack, 1024); // (s_stack_t * stack, int max_size)
    pthread_t tidp, tidc;
    int prc = pthread_create(&tidp, NULL, producer_routine, NULL);
    int crc = pthread_create(&tidc, NULL, consumer_routine, NULL);
    stack_destroy(&stack);
    return 0;
}

客户端只是发送一条消息，然后等待接收一条消息。如果在任何这些线程中调用 write_a_message_to_client() ，即使将 socket_fd 作为参数传递，我也会收到相同的错误。如果直接在main中调用是没有问题的。

编辑#2:

我对此进行了测试，发现我的堆栈实现无法在 Cygwin 上运行。由于某种原因，Cygwin 在第三个元素后添加了乱码，因此套接字 fd 无效。另外，我在 Debian 6 VM 中对此进行了测试，从客户端连接后服务器崩溃了。但我在 Arch、Kali 和我的 Uni 服务器(Debian 7)中测试了它，并且可以正常工作。一大堆麻烦却一事无成。谢谢西格温!

Answer 1

在两个线程都完成之前，不应调用 stack_destroy()。我认为你的整个程序正在使用被破坏的堆栈运行。

使用pthread_join()等待线程完成，然后再销毁堆栈。