rs_taskflow

Attempt at recreating https://github.com/cpp-taskflow/cpp-taskflow in Rust.

Example:

```rust

[derive_task((i32,), (i32,))]

struct FlowTask;

let mut flow = Flow::new();

let a = flow.newtask(FlowTask::new(|x: &i32| *x + 1)); let b = flow.newtask(FlowTask::new(|x: &i32| *x - 2)); let c = flow.new_task(FlowTask::new(|x: &i32| *x + 3));

flow.connectoutput0toinput0(&a, &b); flow.connectoutput0toinput0(&b, &c);

let flowexec = flow.execute().await; let result = flowexec.getoutput0(&c); ```

For a more complete example, see fullexampletest.rs.

Usage

Installation

bash git clone https://github.com/mm318/rs_taskflow.git

Build

For development iterations ```bash

disables use of the macros in rstaskflowderive

cargo test --no-default-features -- --nocapture ```

For testing build with more debug messages bash cargo test -- --nocapture

For testing release build bash cargo test --release -- --nocapture

Requirements

Developed using Ubuntu 20.04 and Rust 1.64.
Tested nightly using ubuntu-latest and latest stable Rust (as fetched by actions-rs/toolchain@v1).