[−][src]Crate fibers_tasque
A tasque extension 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 |
|