TaskProvider.cpp

Go to the documentation of this file.

 
 
#include <mutex>
#include "SEFramework/Task/TaskProvider.h"
 
namespace SourceXtractor {
 
namespace {
  std::mutex task_provider_mutex;
}
 
std::shared_ptr<const Task> TaskProvider::getTask(const PropertyId& property_id) const {
  std::lock_guard<std::mutex> lock(task_provider_mutex);
 
  // tries to find the Task for the property
  auto iterTask = m_tasks.find(property_id);
 
  if (iterTask != m_tasks.end()) {
    return iterTask->second;
  } else if (m_task_factory_registry != nullptr) {
    // Use the TaskFactoryRegistry to get the correct factory for the requested property_id
    try {
      auto& task_factory = m_task_factory_registry->getFactory(property_id.getTypeId());
      auto task = task_factory.createTask(property_id);
 
      // Put it in the cache
      const_cast<TaskProvider&>(*this).m_tasks[property_id] = task;
 
      return task;
    } catch (std::out_of_range&) {
      throw Elements::Exception() << "No TaskFactory for property: " << property_id.getString();
    }
  } else {
    return nullptr;
  }
}
 
} // SEFramework namespace