Crate fibers_tasque [−] [src]
A tasque extention specialized for fibers.
This provides an extension trait and the default task queues.
Examples
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));
Structs
AsyncCall |
A |
AsyncCallError |
An |
DefaultCpuTaskQueue |
The default queue for executing CPU intensive tasks. |
DefaultIoTaskQueue |
The default queue for executing I/O intensive tasks. |
Traits
TaskQueueExt |
|