循环创建线程

Question

像这样在循环中创建线程是否不好？

线程函数示例：

void *thread_func(void* args)
{
  const char *str = (const char *)args;

  printf("Threading %s\n", str);
  usleep(1000);
}

主循环：

pthread_t thread;
while (1) {
    char *str = "test str";
    if (pthread_create(&thread, NULL, thread_func, str)) {
            fprintf(stderr, "Failed to create thread\n");
            return -1;
    }
    usleep(3000);
  /* Thread guaranteed finished here */
  }

或者我必须创建一次并循环使用

Answer 1

您的代码不正确。虽然可以重用pthread_t变量，但是您应该加入每个线程。否则，您的系统可能会很快耗尽资源。

线程休眠任何时间后“保证已完成”的假设也不正确。（此外，如果您要在主线程上休眠直到工作线程完成，为什么首先要创建一个单独的线程？）

因此，让n个线程起作用的一般方法是创建一个由n个线程句柄组成的数组，为每个线程句柄启动一个线程，然后同时执行主线程应该执行的所有操作，最后加入所有线程。

#include <stdio.h>
#include <pthread.h>

#define NTHREADS 10

void * thread_func(void * args);

int
main()
{
  pthread_t threads[NTHREADS];
  void * retvals[NTHREADS];
  int count;
  for (count = 0; count < NTHREADS; ++count)
    {
      if (pthread_create(&threads[count], NULL, thread_func, "...") != 0)
        {
          fprintf(stderr, "error: Cannot create thread # %d\n", count);
          break;
        }
    }
  for (int i = 0; i < count; ++i)
    {
      if (pthread_join(threads[i], &retvals[i]) != 0)
        {
          fprintf(stderr, "error: Cannot join thread # %d\n", i);
        }
    }
}