Method dequeue

src/runtime/task/hpc_task_queue.cpp:53–80

}

task *hpc_concurrent_task_queue::dequeue(int &batch_size)
{
    batch_size = _sema.waitMany(batch_size);
    if (batch_size == 0) {
        return nullptr;
    }
    task *head = nullptr, *last = nullptr;
    auto out = boost::make_function_output_iterator([&head, &last](task *in) {
        if (last) {
            last->next = in;
        } else {
            head = in;
        }

        last = in;
        last->next = nullptr;
    });
    auto count = batch_size;
    do {
        for (auto &qs : _queues) {
            count -= qs.q.try_dequeue_bulk(out, count);
            if (count == 0) {
                break;
            }
        }
    } while (count != 0);
    return head;
}
}
}