From 1b6a04ca5504955c571d1c97504fb45ea0befee4 Mon Sep 17 00:00:00 2001 From: Valentin Popov Date: Mon, 8 Jan 2024 01:21:28 +0400 Subject: Initial vendor packages Signed-off-by: Valentin Popov --- vendor/flume/README.md | 86 ++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 86 insertions(+) create mode 100644 vendor/flume/README.md (limited to 'vendor/flume/README.md') diff --git a/vendor/flume/README.md b/vendor/flume/README.md new file mode 100644 index 0000000..d61155d --- /dev/null +++ b/vendor/flume/README.md @@ -0,0 +1,86 @@ +# Flume + +A blazingly fast multi-producer, multi-consumer channel. + +[![Cargo](https://img.shields.io/crates/v/flume.svg)]( +https://crates.io/crates/flume) +[![Documentation](https://docs.rs/flume/badge.svg)]( +https://docs.rs/flume) +[![License](https://img.shields.io/badge/license-MIT%2FApache--2.0-blue.svg)]( +https://github.com/zesterer/flume) +![actions-badge](https://github.com/zesterer/flume/workflows/Rust/badge.svg?branch=master) + +```rust +use std::thread; + +fn main() { + println!("Hello, world!"); + + let (tx, rx) = flume::unbounded(); + + thread::spawn(move || { + (0..10).for_each(|i| { + tx.send(i).unwrap(); + }) + }); + + let received: u32 = rx.iter().sum(); + + assert_eq!((0..10).sum::(), received); +} +``` + +## Why Flume? + +- **Featureful**: Unbounded, bounded and rendezvous queues +- **Fast**: Always faster than `std::sync::mpsc` and sometimes `crossbeam-channel` +- **Safe**: No `unsafe` code anywhere in the codebase! +- **Flexible**: `Sender` and `Receiver` both implement `Send + Sync + Clone` +- **Familiar**: Drop-in replacement for `std::sync::mpsc` +- **Capable**: Additional features like MPMC support and send timeouts/deadlines +- **Simple**: Few dependencies, minimal codebase, fast to compile +- **Asynchronous**: `async` support, including mix 'n match with sync code +- **Ergonomic**: Powerful `select`-like interface + +## Usage + +To use Flume, place the following line under the `[dependencies]` section in your `Cargo.toml`: + +```toml +flume = "x.y" +``` + +## Cargo Features + +Flume comes with several optional features: + +- `spin`: use spinlocks instead of OS-level synchronisation primitives internally for some kind of data access (may be more performant on a small number of platforms for specific workloads) + +- `select`: Adds support for the [`Selector`](https://docs.rs/flume/latest/flume/select/struct.Selector.html) API, allowing a thread to wait on several channels/operations at once + +- `async`: Adds support for the [async API](https://docs.rs/flume/latest/flume/async/index.html), including on otherwise synchronous channels + +- `eventual-fairness`: Use randomness in the implementation of `Selector` to avoid biasing/saturating certain events over others + +You can enable these features by changing the dependency in your `Cargo.toml` like so: + +```toml +flume = { version = "x.y", default-features = false, features = ["async", "select"] } +``` + +## [Benchmarks](https://what-if.xkcd.com/147/) + +Although Flume has its own extensive benchmarks, don't take it from here that Flume is quick. +The following graph is from the `crossbeam-channel` benchmark suite. + +Tests were performed on an AMD Ryzen 7 3700x with 8/16 cores running Linux kernel 5.11.2 with the bfq scheduler. + +# Flume benchmarks (crossbeam benchmark suite) + +## License + +Flume is licensed under either of: + +- Apache License 2.0, (http://www.apache.org/licenses/LICENSE-2.0) + +- MIT license (http://opensource.org/licenses/MIT) -- cgit v1.2.3