Class executor

Class Documentation

class ral::execution::executor

Public Functions

void execute()
std::exception_ptr last_exception()
bool has_exception()
size_t add_task(std::vector<std::unique_ptr<ral::cache::CacheData>> inputs, std::shared_ptr<ral::cache::CacheMachine> output, ral::cache::kernel *kernel, const std::map<std::string, std::string> &args = {})
void add_task(std::vector<std::unique_ptr<ral::cache::CacheData>> inputs, std::shared_ptr<ral::cache::CacheMachine> output, ral::cache::kernel *kernel, size_t attempts, size_t task_id, const std::map<std::string, std::string> &args = {})
void add_task(std::unique_ptr<task> task)
std::unique_ptr<task> remove_task_from_back()
inline void notify_memory_safety_cv()

Public Static Functions

static inline executor *get_instance()
static inline void init_executor(int num_threads, double processing_memory_limit_threshold)