From fdde1bcb0624ce5232bf0f3226a2f47fd5a24cb3 Mon Sep 17 00:00:00 2001
From: Steven Normore <snormore@gmail.com>
Date: Fri, 11 Apr 2014 13:55:14 +0000
Subject: moar bench package

---
 tx_test.go | 41 +++++++++++++++++++++++++++++++++++++++++
 1 file changed, 41 insertions(+)

(limited to 'tx_test.go')

diff --git a/tx_test.go b/tx_test.go
index 53ec53e..ff0e1e4 100644
--- a/tx_test.go
+++ b/tx_test.go
@@ -365,6 +365,47 @@ func benchmarkTxPutSequential(b *testing.B, total int) {
 	})
 }
 
+// func BenchmarkParallel_1items_1threads(b *testing.B)    { benchmarkParallel(1, 1) }
+// func BenchmarkParallel_1items_10threads(b *testing.B)   { benchmarkParallel(1, 10) }
+// func BenchmarkParallel_1items_100threads(b *testing.B)  { benchmarkParallel(1, 100) }
+// func BenchmarkParallel_1items_1000threads(b *testing.B) { benchmarkParallel(1, 1000) }
+
+// func BenchmarkParallel_10items_1threads(b *testing.B)    { benchmarkParallel(10, 1) }
+// func BenchmarkParallel_10items_10threads(b *testing.B)   { benchmarkParallel(10, 10) }
+// func BenchmarkParallel_10items_100threads(b *testing.B)  { benchmarkParallel(10, 100) }
+// func BenchmarkParallel_10items_1000threads(b *testing.B) { benchmarkParallel(10, 1000) }
+
+// func BenchmarkParallel_100items_1threads(b *testing.B)    { benchmarkParallel(100, 1) }
+// func BenchmarkParallel_100items_10threads(b *testing.B)   { benchmarkParallel(100, 10) }
+// func BenchmarkParallel_100items_100threads(b *testing.B)  { benchmarkParallel(100, 100) }
+// func BenchmarkParallel_100items_1000threads(b *testing.B) { benchmarkParallel(100, 1000) }
+
+// func BenchmarkParallel_1000items_1threads(b *testing.B)    { benchmarkParallel(1000, 1) }
+// func BenchmarkParallel_1000items_10threads(b *testing.B)   { benchmarkParallel(1000, 10) }
+// func BenchmarkParallel_1000items_100threads(b *testing.B)  { benchmarkParallel(1000, 100) }
+// func BenchmarkParallel_1000items_1000threads(b *testing.B) { benchmarkParallel(1000, 1000) }
+
+// func benchmarkParallel(b *testing.B, itemCount, parallelism int) {
+// 	// Setup database.
+// 	for i := 0; i < itemCount; i++ {
+// 		// ... insert key/values here ...
+// 	}
+// 	b.ResetTimer()
+
+// 	// Keep running a fixed number of parallel reads until we run out of time.
+// 	for i := 0; i < b.N; i++ {
+// 		var wg sync.WaitGroup
+// 		for j := 0; j < parallelism; j++ {
+// 			wg.Add(1)
+// 			go func() {
+// 				// ... execute read here ...
+// 				wg.Done()
+// 			}()
+// 		}
+// 		wg.Wait()
+// 	}
+// }
+
 func ExampleTx_Rollback() {
 	// Open the database.
 	db, _ := Open(tempfile(), 0666)
-- 
cgit v1.2.3