Function ThreadMain

test/other/test_malloc_multithreading.c:29–71

#define BASE_SIZE   1000

void *ThreadMain(void *arg) {
  puts("thread started");
  running++;
  void** allocations = (void**)malloc(AT_ONCE * sizeof(void*));
  for (int i = 0; i < AT_ONCE; i++) {
    allocations[i] = NULL;
  }
  for (int i = 0; i < (TOTAL / WORKERS); i++) {
    int rem = i & (AT_ONCE - 1);
    void** allocation = &allocations[rem];
    if (*allocation) {
      free(*allocation);
    }
    *allocation = malloc(BASE_SIZE + rem);
    if (!*allocation) {
      puts("failed to allocate");
      abort();
    }
    char* data = (char*)*allocation;
    *data = i;
  }
  int total = 0;
  for (int i = 0; i < AT_ONCE; i++) {
    void* allocation = allocations[i];
    if (!allocation) {
      puts("did not have allocation");
      abort();
    }
    char* data = (char*)allocation;
    total += *data;
    free(allocation);
  }
  free(allocations);
  printf("thread exiting with total %d\n", total);
  if (atomic_fetch_sub(&running, 1) == 1) {
#if VERBOSE
    double end = emscripten_date_now();
    printf("total time %.2f\n", end - start);
#endif
    printf("Done.\n");
  }
  pthread_exit(0);
}

void CreateThread(int i) {
  pthread_attr_t attr;