Function mandelbrot_thread

test/pthread/test_pthread_mandelbrot.cpp:299–336

_Atomic uint32_t tasksPending[MAX_NUM_THREADS] = {};
#ifndef SINGLETHREADED
void *mandelbrot_thread(void *arg)
{
  long idx = (long)arg;
  numThreadsRunning++;

  char threadName[32];
  sprintf(threadName, "Worker %ld", idx);
  emscripten_set_thread_name(pthread_self(), threadName);

  for(;;)
  {
    while (tasksPending[idx] == 0) {
      emscripten_futex_wait(&tasksPending[idx], 0, INFINITY);
    }
    tasksPending[idx] = 0;
    double t0 = emscripten_get_now();
    int ni;
#ifdef TEST_THREAD_PROFILING
    // If building as part of the harness, do silly things that show up in --threadprofiler,
    // such as sleeping and proxied file i/o ops
    usleep(2000);
    FILE *handle = fopen("a.txt", "w");
    fputs("hello", handle);
    fclose(handle);
#endif
#ifdef __SSE__
    if (use_sse)
      ni = ComputeMandelbrot_SSE(mandelReal, mandelImag, outputImage, sizeof(float)*W, sizeof(uint32_t)*W, 0, (int)idx, numTasks, W, H, left, top, incrX, incrY, numItersDoneOnCanvas, numItersPerFrame);
    else
#endif
      ni = ComputeMandelbrot(mandelReal, mandelImag, outputImage, sizeof(float)*W, sizeof(uint32_t)*W, 0, (int)idx, numTasks, W, H, left, top, incrX, incrY, numItersDoneOnCanvas, numItersPerFrame);
    double t1 = emscripten_get_now();
    numIters[idx] += ni;
    timeSpentInMandelbrot[idx] += t1-t0;
    tasksDone++;
    emscripten_futex_wake(&tasksDone, 9999);
  }
}
#endif

float hScroll = 0;