为什么线程不能正常工作？

Question

我正在解决一个大学练习题。父进程通过管道将在文件中读取的数字 (nThreads) 提供给子进程。子进程必须执行 nThreads 个线程并休眠 nThreads 秒，每个线程必须打印子进程给定的随机数并休眠该随机数秒。 进程打印一切正常，但线程没有。我的代码有什么问题？

...
#include <pthread.h>

void exitError() {
 write(2, "Error!\n", 7);
 exit(1);
}

void *doThread(void* args) {
 long rnd = (long)args;
 printf("Random number = %ld", rnd);
 sleep(rnd);
 pthread_exit((void *)0);
}

int main (int argc, const char * argv[]) {

 int pid, n, piped[2];

 pipe(piped);

 if ((pid=fork()) == -1) {
    write(1, "Error!\n", 4);
    exit(1);
 }
 else if (pid == 0) {   //son
    int nThreads;
    close(piped[1]);
    read(piped[0], &nThreads, 2);
    printf("\nI have to create %d threads\n\n", nThreads);
    pthread_t *threads;
    threads = (pthread_t *) malloc(nThreads*sizeof(pthread_t));

    int random;
    random = rand();
    pthread_create(&threads[nThreads], NULL, doThread, random);

    sleep(nThreads);
    exit(0);
 }
 else {                 //father
    signal(SIGALRM, exitError);
    alarm(10);
    if (argc != 2) {
        write(1, "Command error!\n", 24);
    }   
    int fd = open(argv[1], O_RDONLY);
    char buf[1];
    n = read(fd, buf, 1);
    int nThreads = atoi(buf);
    printf("I say %d to my son\n", nThreads);
    close(piped[0]);
    write(piped[1], &nThreads, 2);
    wait(NULL);
    alarm(0);
    exit(0);
 }

 return 0;
}

如果我做错了什么，请原谅我，这是我第一次在这里提出问题。

Answer 1

有不少错误：

首先，您将指针传递给int random，但在线程中您将参数（指针）转换为数字。您必须将int random 转换为指针，或者在线程中将args 转换为long * 并从该指针读取内存。一旦您启动多个线程，后者实际上将停止工作，因为您将同时更改变量内容，甚至离开该变量的范围。

其次，您无需等待线程。使用pthread_join 等待线程。

第三，你只运行单线程，你需要创建从0到nThreads的循环，一旦启动它们，在类似的循环中调用pthread_join。

第四，int 的大小在大多数平台上是 4，而您只发送 2 个字节。这可能适用于低端平台，但在大端平台上会失败。将sizeof(int) 用于write 和read，使其更便携。