Add concurrent workflow execution capabilities (#4)

* concurrent workflow

* updated deps

* update tokio in readme

* concurrent node registration simplification

* simplified concurrent API

* mix concurrent/sequential example

* simd example

* fmt + clippy

* correct completed/failed counts

* task update helper

Author: nassor

.gitignore

@@ -1 +1,2 @@
 /target
+**/.DS_Store

Cargo.lock

@@ -13,22 +13,31 @@ authors = ["Nassor Frazier-Silva"]
 
 [dependencies]
 async-trait = "0.1"
-tokio = { version = "1.0", features = ["full"] }
+tokio = { version = "1.47", features = ["full"] }
 rand = "0.9"
 cron = "0.15"
 chrono = { version = "0.4", features = ["serde"] }
+futures = "0.3"
 
 [dev-dependencies]
 cargo-audit = "0.21.2"
-criterion = { version = "0.6", features = ["html_reports", "async_tokio"] }
-futures = "0.3"
+criterion = { version = "0.7", features = ["html_reports", "async_tokio"] }
 reqwest = { version = "0.12", features = ["json"] }
 rig-core = "0.15"
+wide = "0.7"
 
 [[example]]
 name = "ai_workflow_yes_and"
 path = "examples/ai_workflow_yes_and.rs"
 
+[[example]]
+name = "workflow_concurrent"
+path = "examples/workflow_concurrent.rs"
+
+[[example]]
+name = "scheduler_mixed_workflows"
+path = "examples/scheduler_mixed_workflows.rs"
+
 [[example]]
 name = "workflow_simple"
 path = "examples/workflow_simple.rs"
@@ -41,6 +50,10 @@ path = "examples/workflow_book_prepositions.rs"
 name = "workflow_negotiation"
 path = "examples/workflow_negotiation.rs"
 
+[[example]]
+name = "workflow_simd_matrix_pipeline"
+path = "examples/workflow_simd_matrix_pipeline.rs"
+
 [[example]]
 name = "workflow_stack_store"
 path = "examples/workflow_stack_store.rs"

Cargo.toml

@@ -1,4 +1,4 @@
-# MIT License
+MIT License
 
 Copyright (c) 2025 Nassor Frazier-Silva