fibers_tasque

针对tasque的fibers扩展。

文档.

lib.rs:

针对tasque的fibers扩展。

提供扩展特质和默认任务队列。

示例

use fibers::{Executor, InPlaceExecutor};
use fibers_tasque::{AsyncCallError, DefaultCpuTaskQueue, DefaultIoTaskQueue, TaskQueueExt};

let mut executor = InPlaceExecutor::new().unwrap();

let future = DefaultCpuTaskQueue.async_call(|| 1 + 1);
assert_eq!(executor.run_future(future).unwrap(), Ok(2));

let future = DefaultIoTaskQueue.async_call(|| -> () { panic!() });
assert_eq!(executor.run_future(future).unwrap(), Err(AsyncCallError));