asonix
83b9aa15b5
All checks were successful
/ check (aarch64-unknown-linux-musl) (push) Successful in 14s
/ check (armv7-unknown-linux-musleabihf) (push) Successful in 11s
/ check (x86_64-unknown-linux-musl) (push) Successful in 11s
/ clippy (push) Successful in 13s
/ tests (push) Successful in 20s
/ build (x86_64-unknown-linux-musl) (push) Successful in 11s
/ loom (notify) (push) Successful in 23s
/ build (aarch64-unknown-linux-musl) (push) Successful in 11s
/ build (armv7-unknown-linux-musleabihf) (push) Successful in 11s
/ loom (queue) (push) Successful in 48s
/ publish-forgejo (push) Successful in 6s
/ publish-crate (push) Successful in 15s
|
||
---|---|---|
.forgejo/workflows | ||
examples | ||
src | ||
tests | ||
.gitignore | ||
Cargo.toml | ||
flake.lock | ||
flake.nix | ||
LICENSE | ||
README.md |
Async CPUPool
A simple async threadpool for CPU-bound tasks
Usage
Add to your Cargo.toml
$ cargo add async-cpupool
Use in your application
fn complex_computation() {}
fn main() -> Result<(), Box<dyn std::error::Error>> {
smol::block_on(async {
let pool = async_cpupool::CpuPool::new();
pool.spawn(move || {
complex_computation();
}).await?;
pool.close().await;
Ok(())
})
}
Contributing
Feel free to open issues for anything you find an issue with. Please note that any contributed code will be licensed under the GPLv3.
License
Copyright © 2023 asonix
Async CPUPool is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
Async CPUPool is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. This file is part of Async CPUPool.
You should have received a copy of the GNU General Public License along with Async CPUPool. If not, see http://www.gnu.org/licenses/.