Method enqueue

common/concurrent_queue.cpp:31–44

}

void ConcurrentQueue::enqueue(Job job)
{
    {
        std::lock_guard<std::mutex> lock(jobsLeftMutex);
        ++jobsLeft;
    }

    {
        std::lock_guard<std::mutex> lock(queueMutex);
        _queue.emplace(std::move(job));
    }

    jobAvailableVar.notify_one();
}

std::size_t ConcurrentQueue::cancelPending()
{