pthread_join() 用于未知数量的线程

Question

main() 中的 poll() 等待来自另一个应用程序的某种触发器，当有触发器时，执行 pollHandler()。在 pollHandler() 中，我想根据轮询消息中的请求数启动“n”个线程。

但是现在在 pollHandler() 中，当我想在不同的 for 循环中使用 pthread_join 时，我无法访问 thread_ids。我可以创建一个 pthread id 数组并在 pthread_create 和 pthread_join 都可以访问的 for 循环块之外使用它，但是 poll() 函数是活动的，它可以一次又一次地被调用，从而覆盖线程身份证。我如何在这里保持清洁 - 等待每个线程完成并腾出空间来拥有更多线程？

int pollHandler(){
int num_req = poll.size();
  for(int i=0; i < num_req; i++){
    // start thread for each req
    pthread_t tid;

    // thread paramters dynamically allocated and freed later
    struct parameters *p = (struct parameters*)malloc(sizeof(struct parameters));

    if((pthread_create(&tid, NULL, thread_func, p) != 0){
      return -1;
    }
  }

  for(int i=0; i < num_req; i++){
    // pthread_join here but no access to thread ids?
  }
 return 0; 
}

int main(){
  ......
  while(1){
    poll(); //waits for a trigger from another application
  }
}

Answer 1

我想根据轮询消息中的请求数启动“n”个线程。

这种设计存在根本缺陷：如果您收到（例如）10,000 个请求的请求，您不太可能创建一个单独的线程来处理每个请求，即使可以，线程的创建和销毁也是效率低下，最好避免。

更好的设计是启动一个线程池，并将工作分派给它们，等待所有工作完成后再返回，正如 Martin James 建议的那样。

也就是说，这是实现您当前设计的正确方法（为清楚起见省略了错误检查）：

int pollHandler(){
  int num_req = poll.size();
  pthread_t *tids = calloc(num_req * sizeof(pthread_t));
  for(int i=0; i < num_req; i++){
    // start thread for each req
    // thread paramters dynamically allocated and freed later
    struct parameters *p = (struct parameters*)malloc(sizeof(struct parameters));

    if((pthread_create(&tid[i], NULL, thread_func, p) != 0){
// bug here.
      return -1;
    }
  }

  for(int i=0; i < num_req; i++){
    pthread_join(tids[i], NULL);
  }
  free(tids);
  return 0;

我可以创建一个 pthread id 数组并在 pthread_create 和 pthread_join 都可以访问的 for 循环块之外使用它，但是 poll() 函数是活动的，它可以被一次又一次地调用，从而覆盖线程 id。

除非pollHandler() 可以中断另一个pollHandler()，否则它不会在之前的调用完成之前被调用，所以上面的代码是“安全的”。

如果pollHandler() 可以作为中断的一部分运行，那么您的代码已经无可救药地被破坏了（malloc 和pthread_create 都不是异步信号安全的，因此不能在信号处理程序中调用）。

附： //bug here 怎么了？

您不能只返回那里 - 您需要加入您已经创建的线程。您还需要在那里free(tids);。