c - 我是线程和信号量的新手，我似乎可以理解为什么我的代码无法正常工作，我们将不胜感激

Question

我正在尝试制作一个带有信号量打印 的代码，但代码无法运行，而且我找不到我的错误。

我也试过 pthread_join，但它是一样的:它不会打印，无论如何。

#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <string.h>
#include <semaphore.h>

sem_t f1, f2, f3;

int done = 1;

void *threadfunc(void *n) {
    int a = 0;

    while (1) {
        if ((int)*(int *)n == 1) {
            //printf("1st THREAD!\n");
            printf("<ONE>");
            sem_wait(&f1);
        } else if ((int)*(int *)n == 2) {
            //printf("2st THREAD!\n");
            printf("<TWO>");
            sem_wait(&f2);
        } else {
            //printf("3st THREAD!\n");
            printf("<THREE>");
            sem_wait(&f3);
        }

        //}

        if (done == 3) {
            done = 1;
            sem_post(&f1);
        } else if (done == 1) {
            done = 2;
            sem_post(&f2);
        } else if (done == 2) {
            done = 3;
            sem_post(&f3);
        }
    }
}

int main() {
    pthread_t tid1, tid2, tid3;
    int n1 = 1, n2 = 2, n3 = 3;

    for (;;) {
        // Create 3 threads
        pthread_create(&tid1, NULL, threadfunc, (void *)&n1);
        sleep(1);

        pthread_create(&tid2, NULL, threadfunc, (void *)&n2);
        sleep(1);

        pthread_create(&tid3, NULL, threadfunc, (void *)&n3);
        sleep(1);

        // infinite loop to avoid exit of a program/process
    }

    return 0;
}

预期输出:一二三一二三 等。

实际输出:无

Answer 1

您的代码中存在多个问题:

• 您启动的不仅仅是三个线程，而是无限数量的线程。您代码中的注释表明，这样做的目的可能是防止主线程退出，但这是解决问题的完全不合适的方法。通常的方法是 pthread_join() 您的线程，或者可能只是 sigsuspend() 或 pause()。

• 你使用你的信号量而不初始化它们。因此，所有信号量函数的行为都是未定义的。您必须在程序的开头使用sem_init() 来初始化每个信号量的状态，包括但不限于其初始值。可能其中一个应该用值 1 初始化，而其他的应该用值 0 初始化。

• 您的线程函数的结构很奇怪。通常等待信号量首先，然后做任何工作，最后发布下一个信号量。但是，即使您按原样安排信号量操作，我也认为变量 done 没有任何意义。你对它的使用与你对 n 的使用是完全多余的。两者传达相同的信息:线程的身份。

• 如果您希望每个线程打印的数据立即出现，那么您应该在每次 printf() 调用之后fflush(stdout)。

• 如果你想在打印之间有延迟，那么你应该把它放在线程函数中，而不是 main() 中。