Merge pull request #8 from insight-platform/benchmark

Add benchmark test for mpmc queue

queue_rs/benches/throughput_mpmc_sync.rs

@@ -0,0 +1,47 @@
+#![feature(test)]
+
+extern crate test;
+
+use queue_rs::blocking::MpmcQueue;
+use queue_rs::mpmc::StartPosition;
+use std::time::Duration;
+use test::Bencher;
+
+const COUNT: usize = 10;
+const LABEL: &str = "label";
+
+#[bench]
+fn rw_mixed(b: &mut Bencher) {
+    let block = vec![0u8; 256 * 1024];
+    let path = "/tmp/test_mpmc_b1".to_string();
+    _ = MpmcQueue::remove_db(&path);
+    {
+        let db = MpmcQueue::new(&path, Duration::from_secs(60)).unwrap();
+        b.iter(|| {
+            for _ in 0..COUNT {
+                db.add(&[&block]).unwrap();
+                db.next(1, LABEL, StartPosition::Oldest).unwrap();
+            }
+        });
+    }
+    MpmcQueue::remove_db(&path).unwrap();
+}
+
+#[bench]
+fn write_read(b: &mut Bencher) {
+    let block = vec![0u8; 256 * 1024];
+    let path = "/tmp/test_mpmc_b2".to_string();
+    _ = MpmcQueue::remove_db(&path);
+    {
+        let db = MpmcQueue::new(&path, Duration::from_secs(60)).unwrap();
+        b.iter(|| {
+            for _ in 0..COUNT {
+                db.add(&[&block]).unwrap();
+            }
+            for _ in 0..COUNT {
+                db.next(1, LABEL, StartPosition::Oldest).unwrap();
+            }
+        });
+    }
+    MpmcQueue::remove_db(&path).unwrap();
+}

queue_rs/benches/throughput_sync.rs

@@ -14,7 +14,7 @@ fn rw_mixed(b: &mut Bencher) {
     let path = "/tmp/test_b1".to_string();
     _ = PersistentQueueWithCapacity::remove_db(&path);
     {
-        let mut db = PersistentQueueWithCapacity::new(&path, COUNT, Options::default()).unwrap();
+        let db = PersistentQueueWithCapacity::new(&path, COUNT, Options::default()).unwrap();
         b.iter(|| {
             for _ in 0..COUNT {
                 db.push(&[&block]).unwrap();
@@ -31,7 +31,7 @@ fn write_read(b: &mut Bencher) {
     let path = "/tmp/test_b2".to_string();
     _ = PersistentQueueWithCapacity::remove_db(&path);
     {
-        let mut db = PersistentQueueWithCapacity::new(&path, COUNT, Options::default()).unwrap();
+        let db = PersistentQueueWithCapacity::new(&path, COUNT, Options::default()).unwrap();
         b.iter(|| {
             for _ in 0..COUNT {
                 db.push(&[&block]).unwrap();