#fibers #thread-pool #task-queue #future

fibers_tasque

A tasque extension specialized for fibers

3 releases

0.1.2 May 29, 2019
0.1.1 Jan 19, 2018
0.1.0 Jan 7, 2018

#27 in #thread-pool

Download history 70/week @ 2023-05-31 13/week @ 2023-06-07 74/week @ 2023-06-14 92/week @ 2023-06-21 46/week @ 2023-06-28 200/week @ 2023-07-05 39/week @ 2023-07-12 100/week @ 2023-07-19 64/week @ 2023-07-26 29/week @ 2023-08-02 52/week @ 2023-08-09 57/week @ 2023-08-16 42/week @ 2023-08-23 38/week @ 2023-08-30 75/week @ 2023-09-06 49/week @ 2023-09-13

204 downloads per month
Used in 11 crates (6 directly)

MIT license

10KB
143 lines

fibers_tasque

fibers_tasque Documentation Build Status Code Coverage License: MIT

A tasque extension specialized for fibers.

Documentation.


lib.rs:

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));

Dependencies

~2–2.7MB
~55K SLoC