文件名称：槽-惊人的快速多生产商频道-Rust开发
文件大小：136KB
文件格式：ZIP
更新时间：2024-06-16 12:03:28
Rust Concurrency
Flume一个惊人的快速多生产者，单消费者渠道。 let（tx，rx）= flume :: unbounded（）; thread :: spawn（move || {for i in 0..10 {Flume一个非常快的多生产者，单用户通道。let（tx，rx）= flume :: unbounded（）; thread :: spawn（move || {对于0..10中的i {tx.send（i）;}}）;接收= rx .iter（）.sum（）; assert_eq！（（0..10）.sum（），已接收）;功能有界/*队列没有不安全的代码简单的设计，很少的依赖关系，非常快速地编译异步支持的select-like接口（请参阅示例/select.rs）与std :: sync :: mpsc的功能奇偶用法用法要使用Flume，请放置f
【文件预览】：
flume-master
----LICENSE-MIT(1022B)
----Cargo.toml(1KB)
----.github()
--------workflows()
----src()
--------signal.rs(1KB)
--------select.rs(13KB)
--------async.rs(16KB)
--------lib.rs(31KB)
----LICENSE-APACHE(11KB)
----examples()
--------select.rs(704B)
--------async.rs(447B)
--------simple.rs(323B)
--------perf.rs(690B)
----README.md(2KB)
----tests()
--------array.rs(15KB)
--------golang.rs(40KB)
--------select_macro.rs(34KB)
--------method_sharing.rs(2KB)
--------tick.rs(9KB)
--------thread_locals.rs(1KB)
--------basic.rs(9KB)
--------same_channel.rs(3KB)
--------select.rs(38KB)
--------never.rs(2KB)
--------async.rs(6KB)
--------mpsc.rs(54KB)
--------after.rs(8KB)
--------iter.rs(2KB)
--------list.rs(12KB)
--------zero.rs(13KB)
--------stream.rs(6KB)
--------ready.rs(22KB)
----misc()
--------benchmarks.png(85KB)
----.gitignore(19B)
----CHANGELOG.md(1KB)
----benches()
--------basic.rs(15KB)