Function main

test/pthread/test_pthread_create.c:66–93

}

int main() {
  // Create initial threads.
  for (int i = 0; i < NUM_THREADS; ++i)
    CreateThread(i);

  int numThreadsToCreate = 1000;

  // Join all threads and create more.
  while (numThreadsToCreate > 0) {
    for (int i = 0; i < NUM_THREADS; ++i) {
      if (thread[i]) {
        intptr_t status;
        int rc = pthread_join(thread[i], (void**)&status);
        assert(rc == 0);
        emscripten_errf("Main: Joined thread idx %d (param %d) with status %d", i, global_shared_data[i], (int)status);
        assert(status == N);
        thread[i] = 0;
        if (numThreadsToCreate > 0) {
          --numThreadsToCreate;
          CreateThread(i);
        }
      }
    }
  }

  printf("All threads joined.\n");
  return 0;
}