blob: 87cb5e57440e719db41af6c48f5fa8e973b4ed7a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
|
use futures::Future;
use utils::SendBoxFuture;
use futures_cpupool::{Builder, CpuPool};
use context::OffloaderComponent;
/// Create a `futures_cpupool::CpuPool` with default parameters.
///
/// Note that this crate implements `OffloaderComponent` for `CpuPool`.
/// (Which is a component of the context used to build/encode mails and
/// should not be confused with header components).
pub fn simple_cpu_pool() -> CpuPool {
Builder::new().create()
}
impl OffloaderComponent for CpuPool {
/// executes the futures `fut` "elswhere" e.g. in a cpu pool
fn offload<F>(&self, fut: F) -> SendBoxFuture<F::Item, F::Error>
where
F: Future + Send + 'static,
F::Item: Send + 'static,
F::Error: Send + 'static,
{
Box::new(self.spawn(fut))
}
}
#[cfg(test)]
mod test {
use super::*;
use futures::future;
use futures_cpupool::Builder;
#[test]
fn check_if_it_works() {
let pool = Builder::new().create();
_check_if_it_works(pool)
}
fn _check_if_it_works<R: OffloaderComponent>(r: R) {
let res = r
.offload(future::lazy(|| -> Result<u32, ()> { Ok(33u32) }))
.wait();
let val = assert_ok!(res);
assert_eq!(33u32, val);
}
}
|
