Thread System 0.3.1
High-performance C++20 thread pool with work stealing and DAG scheduling
Loading...
Searching...
No Matches
kcenon::thread::dag_scheduler Member List

This is the complete list of members for kcenon::thread::dag_scheduler, including all inherited members.

active_callbacks_kcenon::thread::dag_schedulerprivate
add_dependency(job_id dependent, job_id dependency) -> common::VoidResultkcenon::thread::dag_scheduler
add_job(std::unique_ptr< dag_job > j) -> job_idkcenon::thread::dag_scheduler
add_job(dag_job_builder &&builder) -> job_idkcenon::thread::dag_scheduler
are_dependencies_satisfied(job_id id) const -> boolkcenon::thread::dag_schedulerprivate
cancel_all() -> voidkcenon::thread::dag_scheduler
cancel_dependents(job_id failed_id) -> voidkcenon::thread::dag_schedulerprivate
cancelled_kcenon::thread::dag_schedulerprivate
completion_cv_kcenon::thread::dag_schedulerprivate
config_kcenon::thread::dag_schedulerprivate
dag_scheduler(std::shared_ptr< thread_pool > pool, dag_config config={})kcenon::thread::dag_schedulerexplicit
dag_scheduler(const dag_scheduler &)=deletekcenon::thread::dag_scheduler
dag_scheduler(dag_scheduler &&) noexceptkcenon::thread::dag_scheduler
dependencies_kcenon::thread::dag_schedulerprivate
dependents_kcenon::thread::dag_schedulerprivate
detect_cycle() const -> boolkcenon::thread::dag_schedulerprivate
execute(job_id target) -> std::future< common::VoidResult >kcenon::thread::dag_scheduler
execute_all() -> std::future< common::VoidResult >kcenon::thread::dag_scheduler
execute_job(job_id id) -> voidkcenon::thread::dag_schedulerprivate
executing_kcenon::thread::dag_schedulerprivate
execution_start_time_kcenon::thread::dag_schedulerprivate
first_error_kcenon::thread::dag_schedulerprivate
get_all_jobs() const -> std::vector< dag_job_info >kcenon::thread::dag_scheduler
get_config() const -> const dag_config &kcenon::thread::dag_schedulerinline
get_execution_order() const -> std::vector< job_id >kcenon::thread::dag_scheduler
get_job_info(job_id id) const -> std::optional< dag_job_info >kcenon::thread::dag_scheduler
get_jobs_in_state(dag_job_state state) const -> std::vector< dag_job_info >kcenon::thread::dag_scheduler
get_ready_jobs() const -> std::vector< job_id >kcenon::thread::dag_scheduler
get_result(job_id id) const -> const T &kcenon::thread::dag_schedulerinline
get_state_color(dag_job_state state) -> std::stringkcenon::thread::dag_schedulerprivatestatic
get_stats() const -> dag_statskcenon::thread::dag_scheduler
has_cycles() const -> boolkcenon::thread::dag_scheduler
is_execution_complete() const -> boolkcenon::thread::dag_schedulerprivate
jobs_kcenon::thread::dag_schedulerprivate
mutex_kcenon::thread::dag_schedulermutableprivate
on_job_completed(job_id id) -> voidkcenon::thread::dag_schedulerprivate
on_job_failed(job_id id, const std::string &error) -> voidkcenon::thread::dag_schedulerprivate
operator=(const dag_scheduler &) -> dag_scheduler &=deletekcenon::thread::dag_scheduler
operator=(dag_scheduler &&) noexcept -> dag_scheduler &kcenon::thread::dag_scheduler
pool_kcenon::thread::dag_schedulerprivate
remove_job(job_id id) -> common::VoidResultkcenon::thread::dag_scheduler
reset() -> common::VoidResultkcenon::thread::dag_scheduler
retry_counts_kcenon::thread::dag_schedulerprivate
running_count_kcenon::thread::dag_schedulerprivate
schedule_ready_jobs() -> voidkcenon::thread::dag_schedulerprivate
skip_dependents(job_id failed_id) -> voidkcenon::thread::dag_schedulerprivate
to_dot() const -> std::stringkcenon::thread::dag_scheduler
to_json() const -> std::stringkcenon::thread::dag_scheduler
topological_sort() const -> std::vector< job_id >kcenon::thread::dag_schedulerprivate
wait() -> common::VoidResultkcenon::thread::dag_scheduler
~dag_scheduler()kcenon::thread::dag_scheduler