pthread_create（）在EAGAIN 291周期失败

Question

我有以下代码：

int main(int argc, char** argv)
{
  pthread_t thread[thr_num];
  pthread_attr_t attr;
  pthread_attr_init(&attr);
  pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);

  // just for debugging //
    struct rlimit rlim;
    getrlimit(RLIMIT_NPROC, &rlim);
    printf ("soft = %d \n", rlim.rlim_cur);
    printf ("hard = %d \n", rlim.rlim_max);
  ////

  for ( i = 1 ; i <= thr_num ; i++) {
    if(pthread_create( &thread[i], &attr, loggerThread, (void*)argv ) ) {
      printf("pthread_create failure, i = %d, errno = %d \n", i, errno);
      exit(1);
    }
  }

  pthread_attr_destroy(&attr);

  for ( i = 1 ; i <= thr_num ; i++) {
    if( pthread_join(thread[i], (void**)&status ) ) {
      exit(1);
    }
  }  

  return 0;
}

void* loggerThread(void* data) 
{
  char** sthg = ((char**)data);
  pthread_exit(NULL);
}

我不明白为什么在thr\u num=291的情况下运行此代码时，会出现一个错误：pthread\u create failure，I=291，errno=11（EAGAIN）

使用thr_num=290工作正常。我在Linux-0.2默认值（SLES 11）上运行此代码2.6.27.54rlim.rlim_currlim.rlim_max值6906。我在“最大用户进程”的“ulimited-a”中看到了同样的情况。我还检查了pthread_create手册页引导的 /proc/sys/kernel/threads-max（它是13813）。也没有找到“sysctl-a”输出值为290的任何参数。

偶尔我从这个链接中发现：pthread_create和EAGAIN：“即使调用pthread_exit或pthread_cancel，父进程仍然需要调用pthread_join来释放pthreadID，然后它将变得可回收”

因此，作为尝试，我将我的代码修改为：

for ( i = 1 ; i <= thr_num ; i++) {
  if(pthread_create( &thread[i], &attr, loggerThread, (void*)argv ) ) {
    printf("pthread_create failure, i = %d, errno = %d \n", i, errno);
    exit(1);
  }

  if( pthread_join(thread[i], (void**)&status ) ) {
    printf("pthread_join failure, i = %d, errno = %d \n", i, errno);
    exit(1);
  }     
}
pthread_attr_destroy(&attr);

然后一切都正常了：我在291循环时没有得到错误。

我想了解为什么我的原始代码会出现错误：1。因为线程2的编程错误。或者我达到了我无法识别的系统极限

也想知道我的修正是否对这个问题有好处，或者我最终用这个解决方案引入了什么隐藏的东西、陷阱？谢谢！

Answer 1

我最初写这篇评论，但以防万一。。。

您的代码：

  for ( i = 1 ; i <= thr_num ; i++) {
    if(pthread_create( &thread[i], &attr, loggerThread, (void*)argv ) ) {
      printf("pthread_create failure, i = %d, errno = %d \n", i, errno);
      exit(1);
    }
  }
...
  for ( i = 1 ; i <= thr_num ; i++) {
    if( pthread_join(thread[i], (void**)&status ) ) {
      exit(1);
    }
  }  

在这两个for（）循环中，您都从1-thr\u num进行检查。这意味着您超出了数组线程[thr\u num]的界限，因为数组从索引0开始。因此，您应该从0迭代到小于thr\u num的1：

for ( i = 0 ; i < thr_num ; i++)

我真的很惊讶你在达到291thr_num之前没有出现分段错误。

Answer 2

我想了解为什么我的原始代码会出现错误：1。因为线程2的编程错误。或者我达到了我无法识别的系统极限

您可能达到了系统限制。可能您的地址空间不足。默认情况下，每个线程在linux上获得8-10Mb的堆栈空间。如果创建290个线程，将使用近3Gb的地址空间，这是32位进程的最大地址空间。

在这种情况下，您会得到EAGAIN，因为现在没有足够的资源来创建线程（因为当时没有足够的地址空间可用）。

当一个线程退出时，并不是该线程的所有资源都被释放（在linux上，整个线程堆栈都被保留）。

>

如果线程未分离，则需要对其调用pthread\u join（），以释放资源。

请注意，在循环中调用pthread\u join（）的修改代码将：

1. 生成一个线程
2. 等待该线程完成
3. 转到1

也就是说，一次只有另一个线程在运行——这似乎有点毫无意义。

您当然可以生成多个并发运行的线程，但这是有限制的。在您的机器上，您似乎已经发现限制在290左右。