#fibers #executor #anywhere #test #future #oneshot #sync

dev fibers_global

The global executor of fibers

3 releases

0.1.2 Feb 6, 2019
0.1.1 Jan 28, 2019
0.1.0 Jul 30, 2018

#13 in #oneshot

Download history 55/week @ 2024-11-15 76/week @ 2024-11-22 80/week @ 2024-11-29 114/week @ 2024-12-06 66/week @ 2024-12-13 37/week @ 2024-12-20 20/week @ 2024-12-27 30/week @ 2025-01-03 49/week @ 2025-01-10 53/week @ 2025-01-17 48/week @ 2025-01-24 50/week @ 2025-01-31 73/week @ 2025-02-07 59/week @ 2025-02-14 63/week @ 2025-02-21 56/week @ 2025-02-28

260 downloads per month
Used in 15 crates

MIT license

8KB
99 lines

fibers_global

Documentation Build Status Code Coverage License: MIT

The global executor of fibers.

Documentation

This crate provides the global ThreadPoolExecutor that enables to spawn/execute fibers anywhere in a program.

This is useful for briefly writing test or example code that use fibers.

Examples

use fibers::sync::oneshot;
use futures::{lazy, Future};

// Spawns two auxiliary fibers.
let (tx0, rx0) = oneshot::channel();
let (tx1, rx1) = oneshot::channel();
fibers_global::spawn(lazy(move || {
    let _ = tx0.send(1);
    Ok(())
}));
fibers_global::spawn(lazy(move || {
    let _ = tx1.send(2);
    Ok(())
}));

// Executes a calculation that depends on the above fibers.
let result = fibers_global::execute(rx0.join(rx1).map(|(v0, v1)| v0 + v1));
assert_eq!(result.ok(), Some(3));

Dependencies

~1–1.3MB
~20K SLoC