让主程序等待线程完成

Question

在下面的代码中，我创建了一定数量的线程，每个线程都会休眠几秒钟。

然而，我的主程序不会等待线程完成，我假设线程将继续运行，直到它们自行完成。

即使调用线程完成，是否有某种方法使线程继续运行。

#include <pthread.h>
#include <iostream>
#include <cstdio>
#include <cstdlib>


int sample(int min,int max){
  int r=rand();
  return (r %max+min );
}



void *worker(void *p){
  long i = (long) p;
  int s = sample(1,10);
  fprintf(stdout,"\tid:%ld  will sleep: %d \n",i,s);
  sleep(s);
  fprintf(stdout,"\tid:%ld  done sleeping \n",i,s);
}

pthread_t thread1;

int main(){
  int nThreads = sample(1,10);

  for(int i=0;i<nThreads;i++){
    fprintf(stderr,"\t-> Creating: %d of %d\n",i,nThreads);
    int iret1 = pthread_create( &thread1, NULL, worker, (void*) i);
    pthread_detach(thread1);
  }
  //  sleep(10);//work if this is not commented out.
  return 0;
}

谢谢

编辑：

抱歉没有澄清，是否可以在不明确跟踪我当前正在运行的线程并使用 join.

Answer 1

每个程序都有一个主线程。它是 main() 函数执行的线程。当该线程的执行完成时，程序及其所有线程也将完成。如果您希望主线程等待其他线程，则必须使用 pthread_join 功能

Answer 2

您需要跟踪线程。您没有这样做，因为您正在创建的每个线程都使用相同的 thread1 变量。

您可以通过创建传递给 pthread_create() 函数的 pthread_t 类型列表（或数组）来跟踪线程。然后你pthread_join()列表中的那些线程。

编辑：

嗯，你真的很懒，不跟踪正在运行的线程。但是，您可以通过在线程结束之前增加一个全局变量（受互斥锁保护）来实现您想要的目的。然后在主线程中，您可以检查该 var 是否达到您想要的值。在示例代码中输入nThreads。

Answer 3

您需要加入您创建的每个线程：

int main()
{
    int                    nThreads = sample(1,10);
    std::vector<pthread_t> threads(nThreads);

    for(i=0; i<nThreads; i++)
    {
            pthread_create( &threads[i], NULL, worker, (void*) i)
    }

    /* Wait on the other threads */
    for(i=0; i<nThreads; i++)
    {
            status*   status;
            pthread_join(threads[i], &status);
    }
}

Answer 4

你知道你的假设是错误的。主要是特别。退出 main 会杀死你的线程。所以有两个选择：

1. 使用pthread_exit退出main。此函数将允许您退出 main，但保持其他线程运行。

2. 做一些事情来保持 main 的存活。这可以是任何东西，从循环（愚蠢且低效）到任何阻塞调用。 pthread_join 很常见，因为它会阻塞，但如果您感兴趣的话，还会为您提供线程的返回状态，并清理死线程资源。但为了防止 main 终止，任何阻塞调用都会执行，例如选择、读取管道、阻塞信号量等。

由于 Martin 展示了 join()，这里是 pthread_exit()< /代码>：

int main(){
  int nThreads = sample(1,10);

  for(int i=0;i<nThreads;i++){
    fprintf(stderr,"\t-> Creating: %d of %d\n",i,nThreads);
    int iret1 = pthread_create( &thread1, NULL, worker, (void*) i);
    pthread_detach(thread1);
  }

  pthread_exit(NULL);
}