Function thread_loop

example/plugins/c-api/thread_pool/thread.cc:152–176

}

void *
thread_loop(void *arg ATS_UNUSED)
{
  /* Infinite loop */
  for (;;) {
    /* returns a job or null if no jobs to do */
    auto job_todo = static_cast<Job *>(remove_from_queue(&job_queue));

    if (job_todo != nullptr) {
      TSAssert(job_todo->magic == MAGIC_ALIVE);

      /* Simply execute the job function */
      job_todo->func(job_todo->cont, job_todo->data);

      /* Destroy this job */
      job_delete(job_todo);
    } else {
      /* Sleep until we get awake (probably some work to do) */
      pthread_mutex_lock(&cond_mutex);
      pthread_cond_wait(&cond, &cond_mutex);
      pthread_mutex_unlock(&cond_mutex);
    }
  }
  return nullptr;
}