Method loop

src/runtime/task/task_worker.cpp:228–258

}

void task_worker::loop()
{
    task_queue *q = queue();
    int best_batch_size = pool_spec().dequeue_batch_size;

    while (_is_running) {
        int batch_size = best_batch_size;
        task *task = q->dequeue(batch_size), *next;

        q->decrease_count(batch_size);

#ifndef NDEBUG
        int count = 0;
#endif
        while (task != nullptr) {
            next = task->next;
            task->next = nullptr;
            task->exec_internal();
            task = next;
#ifndef NDEBUG
            count++;
#endif
        }

#ifndef NDEBUG
        CHECK_EQ_MSG(count, batch_size, "returned task count and batch size do not match");
#endif

        _processed_task_count += batch_size;
    }
}

const threadpool_spec &task_worker::pool_spec() const { return pool()->spec(); }