Crate taskflowrs 

Re-exports

pub use executor::Executor;

pub use task::Task;

pub use task::TaskHandle;

pub use taskflow::Taskflow;

pub use subflow::Subflow;

pub use future::TaskflowFuture;

pub use condition::ConditionalHandle;

pub use condition::BranchId;

pub use condition::Loop;

pub use cycle_detection::CycleDetector;

pub use cycle_detection::CycleDetectionResult;

pub use pipeline::ConcurrentPipeline;

pub use pipeline::Token;

pub use pipeline::StageType;

pub use composition::Composition;

pub use composition::CompositionBuilder;

pub use composition::ComposedInstance;

pub use composition::TaskflowComposable;

pub use composition::CloneableWork;

pub use composition::CompositionParams;

pub use composition::ParamValue;

pub use composition::ParameterizedComposition;

pub use composition::CompositionFactory;

pub use advanced::Priority;

pub use advanced::CancellationToken;

pub use advanced::TaskMetadata;

pub use scheduler::Scheduler;

pub use scheduler::FifoScheduler;

pub use scheduler::PriorityScheduler;

pub use scheduler::RoundRobinScheduler;

pub use numa::NumaTopology;

pub use numa::NumaNode;

pub use numa::NumaPinning;

pub use profiler::Profiler;

pub use profiler::ExecutionProfile;

pub use profiler::TaskStats;

pub use visualization::generate_dot_graph;

pub use visualization::save_dot_graph;

pub use visualization::generate_timeline_svg;

pub use visualization::save_timeline_svg;

pub use visualization::generate_html_report;

pub use visualization::save_html_report;

pub use monitoring::PerformanceMetrics;

pub use metrics::Metrics;

pub use metrics::MetricsSummary;

pub use typed_pipeline::TypeSafePipeline;

pub use typed_pipeline::PipelineBuilder;

pub use typed_pipeline::SimplePipeline;

pub use debug::DebugLogger;

pub use debug::LogLevel;

pub use debug::LogEntry;

pub use preemptive::PreemptiveCancellationToken;

pub use preemptive::DeadlineGuard;

pub use preemptive::Preempted;

pub use preemptive::with_deadline;

pub use dynamic_priority::DynamicPriorityScheduler;

pub use dynamic_priority::SharedDynamicScheduler;

pub use dynamic_priority::PriorityHandle;

pub use dynamic_priority::EscalationPolicy;

pub use hwloc_topology::TopologyProvider;

pub use hwloc_topology::HwTopology;

pub use hwloc_topology::HwlocWorkerAffinity;

pub use hwloc_topology::AffinityStrategy;

pub use hwloc_topology::CacheInfo;

pub use hwloc_topology::PackageInfo;

pub use hwloc_topology::BindError;

pub use gpu::GpuDevice;

pub use gpu::GpuBuffer;

pub use gpu::GpuTaskConfig;

pub use gpu_stream::GpuStream;

pub use gpu_stream::StreamPool;

pub use gpu_stream::StreamSet;

pub use gpu_stream::StreamGuard;

pub use gpu_stream::StreamAssignment;

pub use gpu_backend::BackendKind;

pub use gpu_backend::GpuError;

pub use algorithms::parallel_for_each;

pub use algorithms::parallel_reduce;

pub use algorithms::parallel_transform;

pub use algorithms::parallel_sort;

pub use algorithms::parallel_inclusive_scan;

pub use algorithms::parallel_exclusive_scan;

pub use dashboard::DashboardConfig;

pub use dashboard::DashboardHandle;

pub use dashboard::DashboardServer;

pub use flamegraph::FlamegraphConfig;

pub use flamegraph::FlamegraphGenerator;

pub use regression::Baseline;

pub use regression::MetricComparison;

pub use regression::RegressionDetector;

pub use regression::RegressionReport;

pub use regression::RegressionThresholds;

pub use regression::Severity;

pub use regression::Violation;

Modules

advanced

algorithms

composition

condition

cycle_detection

dashboard

debug

dynamic_priority

Dynamic priority adjustment for queued tasks. See dynamic_priority::SharedDynamicScheduler and dynamic_priority::PriorityHandle. Dynamic priority adjustment for queued tasks.

executor

flamegraph

future

gpu

gpu_backend

gpu_stream

hwloc_topology

Hardware topology via hwloc (or sysfs fallback). See hwloc_topology::TopologyProvider and hwloc_topology::HwlocWorkerAffinity. Hardware topology integration via hwloc.

metrics

monitoring

numa

pipeline

preemptive

Preemptive task cancellation (watchdog + signal-based). See preemptive::PreemptiveCancellationToken and preemptive::with_deadline. Preemptive task cancellation

profiler

regression

scheduler

subflow

task

taskflow

typed_pipeline

visualization

Macros

log_debug

Macro for convenient logging