VuoModuleCompilationQueue.cc

Go to the documentation of this file.

 
#include "VuoModuleCompilationQueue.hh"
 
VuoModuleCompilationQueue::Item::Item()
{
    sourceFile = nullptr;
    loadingGroup = nullptr;
}
 
VuoModuleCompilationQueue::VuoModuleCompilationQueue()
{
}
 
void VuoModuleCompilationQueue::enqueue(VuoModuleCompilationQueue::Item *item)
{
    std::unique_lock<std::mutex> lock(queueMutex);
 
    queue[item->sourcePath].push_back({item, false});
}
 
VuoModuleCompilationQueue::Item * VuoModuleCompilationQueue::next()
{
    Item *item = nullptr;
 
    std::unique_lock<std::mutex> lock(queueMutex);
    queueChanged.wait(lock, [this, &item](){
 
        for (auto &i : queue)
        {
            if (! i.second.front().second)
            {
                item = i.second.front().first;
                i.second.front().second = true;
                return true;
            }
        }
 
        return false;
    });
 
    return item;
}
 
void VuoModuleCompilationQueue::completed(VuoModuleCompilationQueue::Item *item)
{
    std::unique_lock<std::mutex> lock(queueMutex);
 
    auto i = queue.find(item->sourcePath);
 
    delete i->second.front().first;
    i->second.pop_front();
 
    if (i->second.empty())
        queue.erase(i);
 
    queueChanged.notify_one();
}