denyhosts/clamav/libclamav_rust/.cargo/vendor/flume
2023-01-14 18:28:39 +08:00
..
benches 更新libclamav库1.0.0版本 2023-01-14 18:28:39 +08:00
examples 更新libclamav库1.0.0版本 2023-01-14 18:28:39 +08:00
src 更新libclamav库1.0.0版本 2023-01-14 18:28:39 +08:00
tests 更新libclamav库1.0.0版本 2023-01-14 18:28:39 +08:00
.cargo-checksum.json 更新libclamav库1.0.0版本 2023-01-14 18:28:39 +08:00
Cargo.lock 更新libclamav库1.0.0版本 2023-01-14 18:28:39 +08:00
Cargo.toml 更新libclamav库1.0.0版本 2023-01-14 18:28:39 +08:00
CHANGELOG.md 更新libclamav库1.0.0版本 2023-01-14 18:28:39 +08:00
LICENSE-APACHE 更新libclamav库1.0.0版本 2023-01-14 18:28:39 +08:00
LICENSE-MIT 更新libclamav库1.0.0版本 2023-01-14 18:28:39 +08:00
README.md 更新libclamav库1.0.0版本 2023-01-14 18:28:39 +08:00

Flume

A blazingly fast multi-producer, multi-consumer channel.

Cargo Documentation License actions-badge

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::<u32>(), 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:

flume = "x.y"

Benchmarks

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: