sm/cache
1
0
Fork 0
Code

Add benchmarks that use expiring items (time.Now calls) and rename BenchmarkDeleteExpired to BenchmarkDeleteExpiredLoop for clarity

Browse Source
This commit is contained in:
Patrick Mylund Nielsen 2015-11-30 10:45:30 -05:00
parent 28ab885a1a
commit a45ed98559
1 changed files with 41 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
cache_test.go
View File

@ -1425,9 +1425,17 @@ func TestSerializeUnserializable(t *testing.T) {
} }
} }
func BenchmarkCacheGet(b *testing.B) { func BenchmarkCacheGetExpiring(b *testing.B) {
benchmarkCacheGet(b, 5 * time.Minute)
}
func BenchmarkCacheGetNotExpiring(b *testing.B) {
benchmarkCacheGet(b, NoExpiration)
}
func benchmarkCacheGet(b *testing.B, exp time.Duration) {
b.StopTimer() b.StopTimer()
tc := New(DefaultExpiration, 0) tc := New(exp, 0)
tc.Set("foo", "bar", DefaultExpiration) tc.Set("foo", "bar", DefaultExpiration)
b.StartTimer() b.StartTimer()
for i := 0; i < b.N; i++ { for i := 0; i < b.N; i++ {
@ -1449,9 +1457,17 @@ func BenchmarkRWMutexMapGet(b *testing.B) {
} }
} }
func BenchmarkCacheGetConcurrent(b *testing.B) { func BenchmarkCacheGetConcurrentExpiring(b *testing.B) {
benchmarkCacheGetConcurrent(b, 5 * time.Minute)
}
func BenchmarkCacheGetConcurrentNotExpiring(b *testing.B) {
benchmarkCacheGetConcurrent(b, NoExpiration)
}
func benchmarkCacheGetConcurrent(b *testing.B, exp time.Duration) {
b.StopTimer() b.StopTimer()
tc := New(DefaultExpiration, 0) tc := New(exp, 0)
tc.Set("foo", "bar", DefaultExpiration) tc.Set("foo", "bar", DefaultExpiration)
wg := new(sync.WaitGroup) wg := new(sync.WaitGroup)
workers := runtime.NumCPU() workers := runtime.NumCPU()
@ -1493,13 +1509,21 @@ func BenchmarkRWMutexMapGetConcurrent(b *testing.B) {
wg.Wait() wg.Wait()
} }
func BenchmarkCacheGetManyConcurrent(b *testing.B) { func BenchmarkCacheGetManyConcurrentExpiring(b *testing.B) {
benchmarkCacheGetManyConcurrent(b, 5 * time.Minute)
}
func BenchmarkCacheGetManyConcurrentNotExpiring(b *testing.B) {
benchmarkCacheGetManyConcurrent(b, NoExpiration)
}
func benchmarkCacheGetManyConcurrent(b *testing.B, exp time.Duration) {
// This is the same as BenchmarkCacheGetConcurrent, but its result // This is the same as BenchmarkCacheGetConcurrent, but its result
// can be compared against BenchmarkShardedCacheGetManyConcurrent // can be compared against BenchmarkShardedCacheGetManyConcurrent
// in sharded_test.go. // in sharded_test.go.
b.StopTimer() b.StopTimer()
n := 10000 n := 10000
tc := New(DefaultExpiration, 0) tc := New(exp, 0)
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)
@ -1521,9 +1545,17 @@ func BenchmarkCacheGetManyConcurrent(b *testing.B) {
wg.Wait() wg.Wait()
} }
func BenchmarkCacheSet(b *testing.B) { func BenchmarkCacheSetExpiring(b *testing.B) {
benchmarkCacheSet(b, 5 * time.Minute)
}
func BenchmarkCacheSetNotExpiring(b *testing.B) {
benchmarkCacheSet(b, NoExpiration)
}
func benchmarkCacheSet(b *testing.B, exp time.Duration) {
b.StopTimer() b.StopTimer()
tc := New(DefaultExpiration, 0) tc := New(exp, 0)
b.StartTimer() b.StartTimer()
for i := 0; i < b.N; i++ { for i := 0; i < b.N; i++ {
tc.Set("foo", "bar", DefaultExpiration) tc.Set("foo", "bar", DefaultExpiration)
@ -1602,7 +1634,7 @@ func BenchmarkIncrementInt(b *testing.B) {
} }
} }
func BenchmarkDeleteExpired(b *testing.B) { func BenchmarkDeleteExpiredLoop(b *testing.B) {
b.StopTimer() b.StopTimer()
tc := New(5 * time.Minute, 0) tc := New(5 * time.Minute, 0)
tc.mu.Lock() tc.mu.Lock()