Initial vendor packages

Signed-off-by: Valentin Popov <valentin@popov.link>

1 files changed, 30 insertions, 0 deletions

diff --git a/vendor/flume/examples/perf.rs b/vendor/flume/examples/perf.rs
new file mode 100644
index 0000000..054dcbd
--- /dev/null
+++ b/vendor/flume/examples/perf.rs
@@ -0,0 +1,30 @@
+fn main() {
+    let thread_num = 32;
+    let msg_num = 16;
+
+    let (mut main_tx, main_rx) = flume::bounded::<()>(1);
+
+    for _ in 0..thread_num {
+        let (mut tx, rx) = flume::bounded(1);
+        std::mem::swap(&mut tx, &mut main_tx);
+
+        std::thread::spawn(move || {
+            for msg in rx.iter() {
+                tx.send(msg).unwrap();
+            }
+        });
+    }
+
+    for _ in 0..1000 {
+        let main_tx = main_tx.clone();
+        std::thread::spawn(move || {
+            for _ in 0..msg_num {
+                main_tx.send(Default::default()).unwrap();
+            }
+        });
+
+        for _ in 0..msg_num {
+            main_rx.recv().unwrap();
+        }
+    }
+}