sm/cache
1
0
Fork 0
Code

Add expiring/notexpiring sharded cache benchmarks

Browse Source
This commit is contained in:
Patrick Mylund Nielsen 2015-11-30 16:04:49 -05:00
parent afadf13f9f
commit 9fc6f9c73f
1 changed files with 21 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
sharded_test.go
View File

@ -4,6 +4,7 @@ import (
"strconv" "strconv"
"sync" "sync"
"testing" "testing"
"time"
) )
// func TestDjb33(t *testing.T) { // func TestDjb33(t *testing.T) {
@ -32,9 +33,17 @@ func TestShardedCache(t *testing.T) {
} }
} }
func BenchmarkShardedCacheGet(b *testing.B) { func BenchmarkShardedCacheGetExpiring(b *testing.B) {
benchmarkShardedCacheGet(b, 5 * time.Minute)
}
func BenchmarkShardedCacheGetNotExpiring(b *testing.B) {
benchmarkShardedCacheGet(b, NoExpiration)
}
func benchmarkShardedCacheGet(b *testing.B, exp time.Duration) {
b.StopTimer() b.StopTimer()
tc := unexportedNewSharded(DefaultExpiration, 0, 10) tc := unexportedNewSharded(exp, 0, 10)
tc.Set("foobarba", "zquux", DefaultExpiration) tc.Set("foobarba", "zquux", DefaultExpiration)
b.StartTimer() b.StartTimer()
for i := 0; i < b.N; i++ { for i := 0; i < b.N; i++ {
@ -42,10 +51,18 @@ func BenchmarkShardedCacheGet(b *testing.B) {
} }
} }
func BenchmarkShardedCacheGetManyConcurrent(b *testing.B) { func BenchmarkShardedCacheGetManyConcurrentExpiring(b *testing.B) {
benchmarkShardedCacheGetManyConcurrent(b, 5 * time.Minute)
}
func BenchmarkShardedCacheGetManyConcurrentNotExpiring(b *testing.B) {
benchmarkShardedCacheGetManyConcurrent(b, NoExpiration)
}
func benchmarkShardedCacheGetManyConcurrent(b *testing.B, exp time.Duration) {
b.StopTimer() b.StopTimer()
n := 10000 n := 10000
tsc := unexportedNewSharded(DefaultExpiration, 0, 20) tsc := unexportedNewSharded(exp, 0, 20)
keys := make([]string, n) keys := make([]string, n)
for i := 0; i < n; i++ { for i := 0; i < n; i++ {
k := "foo" + strconv.Itoa(n) k := "foo" + strconv.Itoa(n)