0
gcc (GCC) 4.6.3
c89

你好,

我只是想知道这是否是处理 main 创建的工作线程/后台线程的最佳方法?

我这样做对吗?这是我第一次完成任何多线程程序。只是想确保我走在正确的轨道上,因为这必须扩展以添加更多线程。

我有一个线程用于发送消息,另一个线程用于接收消息。

非常感谢您的任何建议,

int main(void)
{
    pthread_t thread_send;
    pthread_t thread_recv;

    int status = TRUE;

    /* Start thread that will send a message */
    if(pthread_create(&thread_send, NULL, thread_send_fd, NULL) == -1) {
        fprintf(stderr, "Failed to create thread, reason [ %s ]",
                strerror(errno));
        status = FALSE;
    }

    if(status != FALSE) {
        /* Thread send started ok - join with the main thread when its work is done */
        pthread_join(thread_send, NULL);

        /* Start thread to receive messages */
        if(pthread_create(&thread_recv, NULL, thread_receive_fd, NULL) == -1) {
            fprintf(stderr, "Failed to create thread for receiving, reason [ %s ]",
                    strerror(errno));
            status = FALSE;

            /* Cancel the thread send if it is still running as the thread receive failed to start */
            if(pthread_cancel(thread_send) != 0) {
                fprintf(stderr, "Failed to cancel thread for sending, reason [ %s ]",
                        strerror(errno));
            }
        }
    }

    if(status != FALSE) {
        /* Thread receive started ok - join with the main thread when its work is done */
        pthread_join(thread_recv, NULL);
    }

    return 0;
}

用于发送消息的工作线程/后台线程示例,仅作为示例

void *thread_send_fd()
{
    /* Send the messages when done exit */

    pthread_exit(NULL);
}
4

2 回答 2

2

唯一可能证明这种结构是合理的情况是,如果只交换一条消息,即使这样,也可能存在一些问题。

如果要在应用程序运行期间不断地交换消息,则更常见的做法是将两个线程都编写为循环并且永不终止它们。这意味着没有持续的创建/终止/销毁开销,也没有死锁生成器(AKA join)。它确实有一个缺点 - 这意味着您必须参与线程间通信的信号、队列等,但是如果您编写许多多线程应用程序,无论如何都会发生这种情况。

无论哪种方式,通常首先启动 rx 线程。如果先启动 tx 线程,则可能会在 rx 线程启动之前重新调整并丢弃 rx 数据。

于 2012-04-06T17:53:45.307 回答
1

这是每条消息执行一次吗?似乎该调用创建了一个线程来发送 1 条消息,并创建了另一个线程来等待 1 个响应。然后调用,我假设整个程序,只是等待整个事情完成。假设接收者在发送者完成发送之前不能做任何事情,这绝对不会改善程序的实际或感知性能。现在准确地说,我们需要知道发送者和接收者到底在做什么,然后才能确定这样做是否有任何好处。为了任何好处,发送者线程和接收者线程必须有他们可以同时完成的工作......而不是串行的。如果目的是不让程序等待发送和接收事务,那么这根本不会这样做。

于 2012-04-07T23:06:46.610 回答