futures-cputask

This library allows you to run long-running CPU-bound tasks on a secondary thread pool and receive a future you can await on.

Features

Uses Futures 0.3.0
For Async/Await
Runs tasks on a secondary threadpool to avoid blocking one of the main executor threads
Supports the threadpool from threadpool and uvth using their respective cargo feature
Has traits for allowing interoperability with other threadpool implementations
Contains an optional custom attribute async_task to turn a regular function into an async function using this crate

(Note: currently this feature only works with the threadpool and uvth threadpools)

Usage

Add this to your Cargo.toml:

futures-cputask = "0.3.0"

if you want to use the custom attribute, add this:

[dependencies.futures-cputask]
version = "0.3.0"
features = ["derive"]

Example

use futures_cputask::async_task;

#[async_task]
fn long_running_task() -> i64 {
    (0..100_000_000).fold(0i64, |a, b| a.wrapping_add(b))
}

License

Licensed under either of

Apache License, Version 2.0 (LICENSE-APACHE or http://www.apache.org/licenses/LICENSE-2.0)
MIT license (LICENSE-MIT or http://opensource.org/licenses/MIT)

at your option.

Contribution