Generic task queue with worker pool (#82)

* Add initial worker implementation * Change function order * Make structs public, add small assertion * Implement is_empty method * Rename structs * WIP Puzzles test scenario * Recursively go through all puzzle pieces, finish test * Improve comments, handle lagging * Use TaskError in tests * Use failure cases in tests * Add more todos * Add entry to CHANGELOG.md * Add documentation * Add an example * Add comments to jigsaw test * Update documentation, add len() method * We can not test this * Remove len method again * Explain how we're generating test puzzles Co-authored-by: Sam Andreae <contact@samandreae.com>
p2panda · Apr 24, 2022 · fb6e7d7 · fb6e7d7
1 parent 897860c
commit fb6e7d7
Show file tree

Hide file tree

Showing 5 changed files with 773 additions and 4 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -10,6 +10,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ### Added
 
 - Introduce GraphQL endpoint [#81](https://github.com/p2panda/aquadoggo/pull/81)
+- Generic task queue with worker pool [#82](https://github.com/p2panda/aquadoggo/pull/82)
 
 ### Changed
 

diff --git a/Cargo.lock b/Cargo.lock
diff --git a/aquadoggo/Cargo.toml b/aquadoggo/Cargo.toml
@@ -17,8 +17,10 @@ edition = "2018"
 anyhow = "1.0.43"
 async-graphql = "3.0.35"
 async-graphql-axum = "3.0.35"
+async-trait = "0.1.53"
 axum = "0.4.8"
 bamboo-rs-core-ed25519-yasmf = "0.1.0"
+crossbeam-queue = "0.3.5"
 directories = "3.0.2"
 envy = "0.4.2"
 exit-future = "0.2.0"

diff --git a/aquadoggo/src/lib.rs b/aquadoggo/src/lib.rs
@@ -21,6 +21,7 @@ mod rpc;
 mod runtime;
 mod server;
 mod task;
+mod worker;
 
 #[cfg(test)]
 mod test_helpers;